public class DefaultTableStoreReader extends Object implements TableStoreReader
| Constructor and Description |
|---|
DefaultTableStoreReader(AsyncClientInterface ots,
TableStoreReaderConfig config,
Executor executor,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback) |
| Modifier and Type | Method and Description |
|---|---|
void |
addPrimaryKey(String tableName,
PrimaryKey primaryKey) |
void |
addPrimaryKeys(String tableName,
List<PrimaryKey> primaryKeys) |
Future<ReaderResult> |
addPrimaryKeysWithFuture(String tableName,
List<PrimaryKey> primaryKeys) |
Future<ReaderResult> |
addPrimaryKeyWithFuture(String tableName,
PrimaryKey primaryKey) |
void |
close() |
void |
flush() |
TableStoreReaderConfig |
getConfig() |
ReaderStatistics |
getStatistics() |
void |
send() |
void |
setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback) |
void |
setRowQueryCriteria(RowQueryCriteria rowQueryCriteria) |
void |
startFlushTimer(int flushInterval) |
public DefaultTableStoreReader(AsyncClientInterface ots, TableStoreReaderConfig config, Executor executor, TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback)
public void addPrimaryKey(String tableName, PrimaryKey primaryKey)
addPrimaryKey in interface TableStoreReaderpublic Future<ReaderResult> addPrimaryKeyWithFuture(String tableName, PrimaryKey primaryKey)
addPrimaryKeyWithFuture in interface TableStoreReaderpublic void addPrimaryKeys(String tableName, List<PrimaryKey> primaryKeys)
addPrimaryKeys in interface TableStoreReaderpublic Future<ReaderResult> addPrimaryKeysWithFuture(String tableName, List<PrimaryKey> primaryKeys)
addPrimaryKeysWithFuture in interface TableStoreReaderpublic void setRowQueryCriteria(RowQueryCriteria rowQueryCriteria)
setRowQueryCriteria in interface TableStoreReaderpublic void send()
send in interface TableStoreReaderpublic void flush()
flush in interface TableStoreReaderpublic void setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback)
setCallback in interface TableStoreReaderpublic void close()
close in interface TableStoreReaderpublic void startFlushTimer(int flushInterval)
public ReaderStatistics getStatistics()
public TableStoreReaderConfig getConfig()
Copyright © 2024. All Rights Reserved.