public class PullResultSetReaderImpl extends Object implements PullResultSetReader
PullResultSetReaderImpl.UpstreamSource
to provide batches and optional
selection vector.#start()
to attach the batch. The associated
BatchAccessor
reports if the schema has changed.reader()
to obtain a reader.#release()
to free the memory for the
incoming batch. Or, to call #detach()
to keep
the batch memory.close()
after all batches are read.Modifier and Type | Class and Description |
---|---|
protected static class |
PullResultSetReaderImpl.State |
static interface |
PullResultSetReaderImpl.UpstreamSource |
Constructor and Description |
---|
PullResultSetReaderImpl(PullResultSetReaderImpl.UpstreamSource source) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this reader.
|
boolean |
next()
Advance to the next batch of data.
|
RowSetReader |
reader()
Obtain a reader to iterate over the rows of the batch.
|
TupleMetadata |
schema()
Return the schema for this result set.
|
int |
schemaVersion() |
protected PullResultSetReaderImpl.State |
state() |
public PullResultSetReaderImpl(PullResultSetReaderImpl.UpstreamSource source)
public TupleMetadata schema()
PullResultSetReader
schema
in interface PullResultSetReader
public boolean next()
PullResultSetReader
next
in interface PullResultSetReader
true
if another batch is available,
false
if EOFpublic int schemaVersion()
schemaVersion
in interface PullResultSetReader
public RowSetReader reader()
PullResultSetReader
reader
in interface PullResultSetReader
public void close()
PullResultSetReader
#detach()
first if
you want to preserve the batch memory.close
in interface PullResultSetReader
protected PullResultSetReaderImpl.State state()
Copyright © 1970 The Apache Software Foundation. All rights reserved.