public abstract class AbstractForwardIndexAccessor<Key,Value,DataType> extends java.lang.Object implements ForwardIndexAccessor<Key,Value>
| Constructor and Description |
|---|
AbstractForwardIndexAccessor(DataExternalizer<DataType> externalizer) |
| Modifier and Type | Method and Description |
|---|---|
abstract DataType |
convertToDataType(InputData<Key,Value> data) |
protected abstract InputDataDiffBuilder<Key,Value> |
createDiffBuilder(int inputId,
DataType inputData) |
DataType |
deserializeData(ByteArraySequence sequence) |
static <Data> Data |
deserializeFromByteSeq(ByteArraySequence bytes,
DataExternalizer<Data> externalizer) |
protected int |
getBufferInitialSize(DataType dataType) |
InputDataDiffBuilder<Key,Value> |
getDiffBuilder(int inputId,
ByteArraySequence sequence)
creates a diff builder for given inputId.
|
ByteArraySequence |
serializeIndexedData(DataType data) |
ByteArraySequence |
serializeIndexedData(InputData<Key,Value> data)
serialize indexed data to forward index format.
|
static <Data> ByteArraySequence |
serializeToByteSeq(Data data,
DataExternalizer<Data> externalizer,
int bufferInitialSize) |
public AbstractForwardIndexAccessor(DataExternalizer<DataType> externalizer)
protected abstract InputDataDiffBuilder<Key,Value> createDiffBuilder(int inputId, DataType inputData) throws java.io.IOException
java.io.IOExceptionpublic DataType deserializeData(ByteArraySequence sequence) throws java.io.IOException
java.io.IOExceptionpublic InputDataDiffBuilder<Key,Value> getDiffBuilder(int inputId, ByteArraySequence sequence) throws java.io.IOException
ForwardIndexAccessorgetDiffBuilder in interface ForwardIndexAccessor<Key,Value>java.io.IOExceptionpublic ByteArraySequence serializeIndexedData(InputData<Key,Value> data) throws java.io.IOException
ForwardIndexAccessorserializeIndexedData in interface ForwardIndexAccessor<Key,Value>java.io.IOExceptionpublic ByteArraySequence serializeIndexedData(DataType data) throws java.io.IOException
java.io.IOExceptionprotected int getBufferInitialSize(DataType dataType)
public static <Data> ByteArraySequence serializeToByteSeq(Data data, DataExternalizer<Data> externalizer, int bufferInitialSize) throws java.io.IOException
java.io.IOExceptionpublic static <Data> Data deserializeFromByteSeq(ByteArraySequence bytes, DataExternalizer<Data> externalizer) throws java.io.IOException
java.io.IOException