public class UpdateData<Key,Value> extends AbstractUpdateData<Key,Value>
| Constructor and Description |
|---|
UpdateData(int inputId,
java.util.Map<Key,Value> newData,
ThrowableComputable<InputDataDiffBuilder<Key,Value>,java.io.IOException> currentDataEvaluator,
IndexId<Key,Value> indexId,
ThrowableRunnable<? extends java.io.IOException> forwardIndexUpdate) |
| Modifier and Type | Method and Description |
|---|---|
protected ThrowableComputable<InputDataDiffBuilder<Key,Value>,java.io.IOException> |
getCurrentDataEvaluator() |
protected boolean |
iterateKeys(KeyValueUpdateProcessor<? super Key,? super Value> addProcessor,
KeyValueUpdateProcessor<? super Key,? super Value> updateProcessor,
RemovedKeyProcessor<? super Key> removeProcessor) |
boolean |
newDataIsEmpty() |
java.lang.String |
toString() |
protected void |
updateForwardIndex() |
getInputIdpublic UpdateData(int inputId,
java.util.Map<Key,Value> newData,
ThrowableComputable<InputDataDiffBuilder<Key,Value>,java.io.IOException> currentDataEvaluator,
IndexId<Key,Value> indexId,
ThrowableRunnable<? extends java.io.IOException> forwardIndexUpdate)
protected boolean iterateKeys(KeyValueUpdateProcessor<? super Key,? super Value> addProcessor, KeyValueUpdateProcessor<? super Key,? super Value> updateProcessor, RemovedKeyProcessor<? super Key> removeProcessor) throws StorageException
iterateKeys in class AbstractUpdateData<Key,Value>StorageExceptionpublic boolean newDataIsEmpty()
newDataIsEmpty in class AbstractUpdateData<Key,Value>protected ThrowableComputable<InputDataDiffBuilder<Key,Value>,java.io.IOException> getCurrentDataEvaluator()
protected void updateForwardIndex()
throws java.io.IOException
updateForwardIndex in class AbstractUpdateData<Key,Value>java.io.IOExceptionpublic java.lang.String toString()
toString in class java.lang.Object