Package org.apache.drill.exec.vector
Class RepeatedIntervalVector.Mutator
java.lang.Object
org.apache.drill.exec.vector.BaseValueVector.BaseMutator
org.apache.drill.exec.vector.complex.BaseRepeatedValueVector.BaseRepeatedMutator
org.apache.drill.exec.vector.RepeatedIntervalVector.Mutator
- All Implemented Interfaces:
RepeatedValueVector.RepeatedMutator
,ValueVector.Mutator
- Enclosing class:
- RepeatedIntervalVector
public final class RepeatedIntervalVector.Mutator
extends BaseRepeatedValueVector.BaseRepeatedMutator
implements RepeatedValueVector.RepeatedMutator
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Add an element to the given record index.protected void
add
(int index, IntervalHolder holder) void
add
(int index, RepeatedIntervalHolder holder) void
addSafe
(int rowIndex, int months, int days, int milliseconds) void
void
addSafe
(int index, IntervalHolder holder) void
addSafe
(int index, NullableIntervalHolder 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, RepeatedIntervalHolder 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
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
-
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
public void addSafe(int rowIndex, int months, int days, int milliseconds) -
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
-