org.apache.drill.exec.physical.impl.svremover

Class AbstractCopier

java.lang.Object

org.apache.drill.exec.physical.impl.svremover.AbstractCopier

All Implemented Interfaces:

Copier

Direct Known Subclasses:

AbstractSV2Copier, AbstractSV4Copier

public abstract class AbstractCopier
extends Object
implements Copier

Field Summary

Fields

Modifier and Type	Field and Description
protected VectorContainer	outgoing
protected ValueVector[]	vvOut

Constructor Summary

Constructors

Constructor and Description
AbstractCopier()

Method Summary

Modifier and Type	Method and Description
static void	allocateOutgoing(VectorContainer outgoing, int recordCount)
int	appendRecord(int index)
int	appendRecords(int index, int recordCount)
abstract void	copyEntry(int inIndex, int outIndex)
abstract void	copyEntryIndirect(int inIndex, int outIndex)
int	copyRecords(int index, int recordCount)
void	setup(VectorAccessible incoming, VectorContainer outgoing)
protected void	updateCounts(int numRecords)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

vvOut

protected ValueVector[] vvOut

outgoing

protected VectorContainer outgoing

Constructor Detail

AbstractCopier

public AbstractCopier()

Method Detail

setup

public void setup(VectorAccessible incoming,
                  VectorContainer outgoing)

Specified by:

setup in interface Copier

copyRecords

public int copyRecords(int index,
                       int recordCount)

Specified by:

copyRecords in interface Copier

appendRecord

public int appendRecord(int index)

Specified by:

appendRecord in interface Copier

appendRecords

public int appendRecords(int index,
                         int recordCount)

Specified by:

appendRecords in interface Copier

updateCounts

protected void updateCounts(int numRecords)

copyEntryIndirect

public abstract void copyEntryIndirect(int inIndex,
                                       int outIndex)

copyEntry

public abstract void copyEntry(int inIndex,
                               int outIndex)

allocateOutgoing

public static void allocateOutgoing(VectorContainer outgoing,
                                    int recordCount)