org.apache.flume.channel.recoverable.memory.wal
Class SequenceIDBuffer
java.lang.Object
org.apache.flume.channel.recoverable.memory.wal.SequenceIDBuffer
- All Implemented Interfaces:
- org.apache.hadoop.util.IndexedSortable
public class SequenceIDBuffer
- extends Object
- implements org.apache.hadoop.util.IndexedSortable
Method Summary |
void |
close()
|
int |
compare(int leftIndex,
int rightIndex)
|
boolean |
exists(long value)
|
long |
get(int index)
|
static void |
main(String[] args)
|
void |
put(int index,
long value)
|
int |
size()
|
void |
sort()
|
void |
swap(int leftIndex,
int rightIndex)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SequenceIDBuffer
public SequenceIDBuffer(int size)
compare
public int compare(int leftIndex,
int rightIndex)
- Specified by:
compare
in interface org.apache.hadoop.util.IndexedSortable
exists
public boolean exists(long value)
swap
public void swap(int leftIndex,
int rightIndex)
- Specified by:
swap
in interface org.apache.hadoop.util.IndexedSortable
get
public long get(int index)
put
public void put(int index,
long value)
size
public int size()
close
public void close()
sort
public void sort()
main
public static void main(String[] args)
throws Exception
- Throws:
Exception
Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.