CheckpointCloseableIterableImpl

public class CheckpointCloseableIterableImpl extends Object
implements CheckpointCloseableIterable<T>

CheckpointCloseableIterable implementation which supports lazy initialization of getCheckpoint() value and hasMore().

Nested Class Summary

class CheckpointCloseableIterableImpl.Builder<T> Builder object for CheckpointCloseableIterableImpl  
class CheckpointCloseableIterableImpl.CompareCheckpointCloseableIterableRule<T> A TestRule to compare two instances of CheckpointCloseableIterables. 

Public Method Summary

void
close()
Performs any actions necessary to stop accessing the repository, such as closing the connection.
byte[]
getCheckpoint()
Get current checkpoint value.
boolean
hasMore()
Flag to indicate if more items are available to traverse beyond current set of items returned as part of Iterable.
Iterator<T>
iterator()

Inherited Method Summary

Public Methods

public void close ()

Performs any actions necessary to stop accessing the repository, such as closing the connection.

public byte[] getCheckpoint ()

Get current checkpoint value. Framework is expected to call this method only after iterating through all objects available.

Returns
  • checkpoint value to save

public boolean hasMore ()

Flag to indicate if more items are available to traverse beyond current set of items returned as part of Iterable. Framework is expected to call this method only after iterating through all objects available.

Returns
  • True if more objects are available for processing after current batch. False if no more objects available for traversal.

public Iterator<T> iterator ()