public abstract class ArrayConsumer extends BaseConsumer<ListVector>
ResultSet
.
Write the data to ListVector
.Modifier and Type | Field and Description |
---|---|
protected JdbcConsumer |
delegate |
protected int |
innerVectorIndex |
columnIndexInResultSet, currentIndex, vector
Constructor and Description |
---|
ArrayConsumer(ListVector vector,
JdbcConsumer delegate,
int index)
Instantiate a ArrayConsumer.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this consumer, do some clean work such as clear reuse ArrowBuf.
|
static ArrayConsumer |
createConsumer(ListVector vector,
JdbcConsumer delegate,
int index,
boolean nullable)
Creates a consumer for
ListVector . |
void |
resetValueVector(ListVector vector)
Reset the vector within consumer for partial read purpose.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
consume
protected final JdbcConsumer delegate
protected int innerVectorIndex
public ArrayConsumer(ListVector vector, JdbcConsumer delegate, int index)
public static ArrayConsumer createConsumer(ListVector vector, JdbcConsumer delegate, int index, boolean nullable)
ListVector
.public void close() throws Exception
JdbcConsumer
close
in interface AutoCloseable
close
in interface JdbcConsumer<ListVector>
close
in class BaseConsumer<ListVector>
Exception
public void resetValueVector(ListVector vector)
JdbcConsumer
resetValueVector
in interface JdbcConsumer<ListVector>
resetValueVector
in class BaseConsumer<ListVector>
Copyright © 2023 The Apache Software Foundation. All rights reserved.