org.apache.drill.exec.physical.resultSet.impl

Class TestResultSetReader.BatchGenerator

java.lang.Object

org.apache.drill.exec.physical.resultSet.impl.TestResultSetReader.BatchGenerator

All Implemented Interfaces:

PullResultSetReaderImpl.UpstreamSource, PushResultSetReaderImpl.UpstreamSource

Enclosing class:

TestResultSetReader

public static class TestResultSetReader.BatchGenerator
extends Object
implements PullResultSetReaderImpl.UpstreamSource

Constructor Summary

Constructors

Constructor and Description
BatchGenerator(int batchSize, int schema1Count, int schema2Count)

Method Summary

Modifier and Type	Method and Description
VectorContainer	batch()
void	batch1()
void	batch2()
void	close()
boolean	next()
void	release()
int	schemaVersion()
SelectionVector2	sv2()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchGenerator

public BatchGenerator(int batchSize,
                      int schema1Count,
                      int schema2Count)

Method Detail

batch1

public void batch1()

batch2

public void batch2()

close

public void close()

next

public boolean next()

Specified by:

next in interface PullResultSetReaderImpl.UpstreamSource

schemaVersion

public int schemaVersion()

Specified by:

schemaVersion in interface PushResultSetReaderImpl.UpstreamSource

batch

public VectorContainer batch()

Specified by:

batch in interface PushResultSetReaderImpl.UpstreamSource

sv2

public SelectionVector2 sv2()

Specified by:

sv2 in interface PushResultSetReaderImpl.UpstreamSource

release

public void release()

Specified by:

release in interface PullResultSetReaderImpl.UpstreamSource