Package org.apache.bookkeeper.metastore

Class InMemoryMetastoreCursor

java.lang.Object

org.apache.bookkeeper.metastore.InMemoryMetastoreCursor

All Implemented Interfaces:

Closeable, AutoCloseable, MetastoreCursor

class InMemoryMetastoreCursor
extends Object
implements MetastoreCursor

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.bookkeeper.metastore.MetastoreCursor

MetastoreCursor.ReadEntriesCallback

Field Summary

Fields inherited from interface org.apache.bookkeeper.metastore.MetastoreCursor

EMPTY_CURSOR

Constructor Summary

Constructors

Constructor	Description
InMemoryMetastoreCursor(SortedMap<String,Versioned<Value>> map, Set<String> fields, ScheduledExecutorService scheduler)

Method Summary

Modifier and Type	Method	Description
void	asyncReadEntries(int numEntries, MetastoreCursor.ReadEntriesCallback cb, Object ctx)	Asynchronously read entries from the cursor, up to the specified numEntries.
void	close()
boolean	hasMoreEntries()	Is there any entries left in the cursor to read.
Iterator<MetastoreTableItem>	readEntries(int numEntries)	Read entries from the cursor, up to the specified numEntries.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InMemoryMetastoreCursor

public InMemoryMetastoreCursor(SortedMap<String,Versioned<Value>> map,
 Set<String> fields,
 ScheduledExecutorService scheduler)

Method Details

hasMoreEntries

public boolean hasMoreEntries()

Description copied from interface: MetastoreCursor

Is there any entries left in the cursor to read.

Specified by:

hasMoreEntries in interface MetastoreCursor

Returns:

true if there is entries left, false otherwise.

readEntries

public Iterator<MetastoreTableItem> readEntries(int numEntries)
                                         throws MSException

Description copied from interface: MetastoreCursor

Read entries from the cursor, up to the specified numEntries. The returned list can be smaller.

Specified by:

readEntries in interface MetastoreCursor

Parameters:

numEntries - maximum number of entries to read

Returns:

the iterator of returned entries.

Throws:

MSException - when failed to read entries from the cursor.

asyncReadEntries

public void asyncReadEntries(int numEntries,
 MetastoreCursor.ReadEntriesCallback cb,
 Object ctx)

Description copied from interface: MetastoreCursor

Asynchronously read entries from the cursor, up to the specified numEntries.

Specified by:

asyncReadEntries in interface MetastoreCursor

Parameters:

numEntries - maximum number of entries to read

cb - callback object

ctx - opaque context

See Also:

• MetastoreCursor.readEntries(int)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException