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() |
getInputId
public 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>
StorageException
public 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.IOException
public java.lang.String toString()
toString
in class java.lang.Object