Package org.apache.drill.exec.vector

Class RepeatedVarBinaryVector.Mutator

java.lang.Object

org.apache.drill.exec.vector.BaseValueVector.BaseMutator

org.apache.drill.exec.vector.complex.BaseRepeatedValueVector.BaseRepeatedMutator

org.apache.drill.exec.vector.RepeatedVarBinaryVector.Mutator

All Implemented Interfaces:

RepeatedValueVector.RepeatedMutator, ValueVector.Mutator

Enclosing class:

RepeatedVarBinaryVector

public final class RepeatedVarBinaryVector.Mutator
extends BaseRepeatedValueVector.BaseRepeatedMutator
implements RepeatedValueVector.RepeatedMutator

Method Summary

Modifier and Type	Method	Description
void	add(int index, byte[] value)	Add an element to the given record index.
void	add(int index, RepeatedVarBinaryHolder holder)
protected void	add(int index, VarBinaryHolder holder)
void	addSafe(int index, byte[] bytes)
void	addSafe(int index, byte[] bytes, int start, int length)
void	addSafe(int rowIndex, int start, int end, DrillBuf buffer)
void	addSafe(int index, NullableVarBinaryHolder holder)
void	addSafe(int index, VarBinaryHolder 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, RepeatedVarBinaryHolder 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 add

value - 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

public void setSafe(int index,
 RepeatedVarBinaryHolder h)

addSafe

public void addSafe(int index,
 VarBinaryHolder holder)

addSafe

public void addSafe(int index,
 NullableVarBinaryHolder holder)

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 forward

index - the current write position to be initialized

addSafe

public void addSafe(int rowIndex,
 int start,
 int end,
 DrillBuf buffer)

add

protected void add(int index,
 VarBinaryHolder holder)

add

public void add(int index,
 RepeatedVarBinaryHolder holder)

generateTestData

public void generateTestData(int valCount)

Specified by:

generateTestData in interface ValueVector.Mutator

Overrides:

generateTestData in class BaseValueVector.BaseMutator

reset

public void reset()

Description copied from interface: ValueVector.Mutator

Resets the mutator to pristine state.

Specified by:

reset in interface ValueVector.Mutator

Overrides:

reset in class BaseValueVector.BaseMutator