Package org.apache.drill.exec.vector
Class RepeatedVarDecimalVector.Mutator
java.lang.Object
org.apache.drill.exec.vector.BaseValueVector.BaseMutator
org.apache.drill.exec.vector.complex.BaseRepeatedValueVector.BaseRepeatedMutator
org.apache.drill.exec.vector.RepeatedVarDecimalVector.Mutator
- All Implemented Interfaces:
RepeatedValueVector.RepeatedMutator
,ValueVector.Mutator
- Enclosing class:
- RepeatedVarDecimalVector
public final class RepeatedVarDecimalVector.Mutator
extends BaseRepeatedValueVector.BaseRepeatedMutator
implements RepeatedValueVector.RepeatedMutator
-
Method Summary
Modifier and TypeMethodDescriptionvoid
add
(int index, byte[] value) Add an element to the given record index.void
add
(int index, RepeatedVarDecimalHolder holder) protected void
add
(int index, VarDecimalHolder holder) void
addSafe
(int index, byte[] bytes) void
addSafe
(int index, byte[] bytes, int start, int length) void
void
addSafe
(int index, NullableVarDecimalHolder holder) void
addSafe
(int index, VarDecimalHolder holder) void
fillEmpties
(int lastWrite, int index) Backfill missing offsets from the given last written position to the given current write position.void
generateTestData
(int valCount) void
reset()
Resets the mutator to pristine state.void
setSafe
(int index, RepeatedVarDecimalHolder h) Methods inherited from class org.apache.drill.exec.vector.complex.BaseRepeatedValueVector.BaseRepeatedMutator
getInnerValueCountAt, setValueCount, startNewValue
Methods inherited from class org.apache.drill.exec.vector.BaseValueVector.BaseMutator
exchange
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.drill.exec.vector.complex.RepeatedValueVector.RepeatedMutator
startNewValue
Methods inherited from interface org.apache.drill.exec.vector.ValueVector.Mutator
exchange, setValueCount
-
Method Details
-
add
public void add(int index, byte[] value) Add an element to the given record index. This is similar to the set() method in other value vectors, except that it permits setting multiple values for a single record.- Parameters:
index
- record of the element to addvalue
- value to add to the given row
-
addSafe
public void addSafe(int index, byte[] bytes) -
addSafe
public void addSafe(int index, byte[] bytes, int start, int length) -
setSafe
-
addSafe
-
addSafe
-
fillEmpties
public void fillEmpties(int lastWrite, int index) Backfill missing offsets from the given last written position to the given current write position. Used by the "new" size-safe column writers to allow skipping values. The set() and setSafe() do not fill empties. See DRILL-5529.- Parameters:
lastWrite
- the position of the last valid write: the offset to be copied forwardindex
- the current write position to be initialized
-
addSafe
-
add
-
add
-
generateTestData
public void generateTestData(int valCount) - Specified by:
generateTestData
in interfaceValueVector.Mutator
- Overrides:
generateTestData
in classBaseValueVector.BaseMutator
-
reset
public void reset()Description copied from interface:ValueVector.Mutator
Resets the mutator to pristine state.- Specified by:
reset
in interfaceValueVector.Mutator
- Overrides:
reset
in classBaseValueVector.BaseMutator
-