R
- Type of the result returned from batch operationV
- Type of the value used in batch operationpublic abstract class GenericBatchExecutionAssistant<R,V> extends Object implements BatchExecutionAssistant<R,V>
BatchExecutionAssistant
.Constructor and Description |
---|
GenericBatchExecutionAssistant() |
Modifier and Type | Method and Description |
---|---|
boolean |
alreadyProcessed(int seqNum)
Checks if row/object with specified sequential number is already processed.
|
protected void |
process(com.datastax.driver.core.Row row)
Processes particular row inside batch operation.
|
void |
process(com.datastax.driver.core.Row row,
int seqNum)
Processes particular row inside batch operation.
|
int |
processedCount() |
R |
processedData() |
boolean |
tableExistenceRequired()
Indicates if Cassandra tables existence is required for this batch operation.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bindStatement, getPersistenceSettings, getStatement, getTable, operationName
public void process(com.datastax.driver.core.Row row, int seqNum)
process
in interface BatchExecutionAssistant<R,V>
row
- Row to process.seqNum
- Sequential number of the row.public boolean alreadyProcessed(int seqNum)
alreadyProcessed
in interface BatchExecutionAssistant<R,V>
seqNum
- object sequential numbertrue
if object is already processedpublic int processedCount()
processedCount
in interface BatchExecutionAssistant<R,V>
public R processedData()
processedData
in interface BatchExecutionAssistant<R,V>
public boolean tableExistenceRequired()
tableExistenceRequired
in interface BatchExecutionAssistant<R,V>
true
true if table existence required.protected void process(com.datastax.driver.core.Row row)
row
- Row to process.
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024