public class VectorKeySeriesMultiSerialized<T extends SerializeWrite> extends VectorKeySeriesSerializedImpl<T> implements VectorKeySeriesSerialized
bufferOffset, output, serializedBytes, serializedKeyLengths, serializedLength, serializedStart, serializeWrite
currentBatchSize, duplicateCounts, hashCodes, nonNullKeyCount, nonNullKeyPosition, seriesCount, seriesIsAllNull, seriesPosition
currentDuplicateCount, currentHasAnyNulls, currentHashCode, currentIsAllNull, currentLogical
Constructor and Description |
---|
VectorKeySeriesMultiSerialized(T serializeWrite) |
Modifier and Type | Method and Description |
---|---|
void |
init(TypeInfo[] typeInfos,
int[] columnNums) |
void |
processBatch(VectorizedRowBatch batch)
Process a non-empty batch of rows and compute a key series.
|
void |
setNextNonNullKey(int nonNullKeyPosition) |
computeSerializedHashCodes, getSerializedBytes, getSerializedLength, getSerializedStart, positionToFirst, validate
advance, next
getCurrentDuplicateCount, getCurrentHasAnyNulls, getCurrentHashCode, getCurrentIsAllNull, getCurrentLogical
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSerializedBytes, getSerializedLength, getSerializedStart
getCurrentDuplicateCount, getCurrentHasAnyNulls, getCurrentHashCode, getCurrentIsAllNull, getCurrentLogical, next, positionToFirst
public VectorKeySeriesMultiSerialized(T serializeWrite)
public void init(TypeInfo[] typeInfos, int[] columnNums) throws HiveException
HiveException
public void processBatch(VectorizedRowBatch batch) throws IOException
VectorKeySeries
processBatch
in interface VectorKeySeries
IOException
public void setNextNonNullKey(int nonNullKeyPosition)
setNextNonNullKey
in class VectorKeySeriesSerializedImpl<T extends SerializeWrite>
Copyright © 2016 The Apache Software Foundation. All rights reserved.