| Package | Description |
|---|---|
| org.apache.arrow.adapter.jdbc | |
| org.apache.arrow.adapter.jdbc.consumer |
| Modifier and Type | Method and Description |
|---|---|
JdbcConsumer |
JdbcToArrowConfig.JdbcConsumerFactory.apply(ArrowType arrowType,
int columnIndex,
boolean nullable,
FieldVector vector,
JdbcToArrowConfig config) |
static JdbcConsumer |
JdbcToArrowUtils.getConsumer(ArrowType arrowType,
int columnIndex,
boolean nullable,
FieldVector vector,
JdbcToArrowConfig config)
Default function used for JdbcConsumerFactory.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ArrayConsumer
Consumer which consume array type values from
ResultSet. |
class |
BaseConsumer<V extends ValueVector>
Base class for all consumers.
|
class |
BinaryConsumer
Consumer which consume binary type values from
ResultSet. |
class |
BlobConsumer
Consumer which consume blob type values from
ResultSet. |
class |
ClobConsumer
Consumer which consume clob type values from
ResultSet. |
class |
CompositeJdbcConsumer
Composite consumer which hold all consumers.
|
class |
Decimal256Consumer
Consumer which consume decimal type values from
ResultSet. |
class |
DecimalConsumer
Consumer which consume decimal type values from
ResultSet. |
class |
MapConsumer
Consumer which consume map type values from
ResultSet. |
class |
NullConsumer
Consumer which consume null type values from ResultSet.
|
| Modifier and Type | Field and Description |
|---|---|
protected JdbcConsumer |
ArrayConsumer.delegate |
| Modifier and Type | Method and Description |
|---|---|
static JdbcConsumer<BigIntVector> |
BigIntConsumer.createConsumer(BigIntVector vector,
int index,
boolean nullable)
Creates a consumer for
BigIntVector. |
static JdbcConsumer<BitVector> |
BitConsumer.createConsumer(BitVector vector,
int index,
boolean nullable)
Creates a consumer for
BitVector. |
static JdbcConsumer<DateDayVector> |
DateConsumer.createConsumer(DateDayVector vector,
int index,
boolean nullable,
Calendar calendar)
Creates a consumer for
DateMilliVector. |
static JdbcConsumer<Decimal256Vector> |
Decimal256Consumer.createConsumer(Decimal256Vector vector,
int index,
boolean nullable,
RoundingMode bigDecimalRoundingMode)
Creates a consumer for
Decimal256Vector. |
static JdbcConsumer<DecimalVector> |
DecimalConsumer.createConsumer(DecimalVector vector,
int index,
boolean nullable,
RoundingMode bigDecimalRoundingMode)
Creates a consumer for
DecimalVector. |
static JdbcConsumer<Float4Vector> |
FloatConsumer.createConsumer(Float4Vector vector,
int index,
boolean nullable)
Creates a consumer for
Float4Vector. |
static JdbcConsumer<Float8Vector> |
DoubleConsumer.createConsumer(Float8Vector vector,
int index,
boolean nullable)
Creates a consumer for
Float8Vector. |
static JdbcConsumer<IntVector> |
IntConsumer.createConsumer(IntVector vector,
int index,
boolean nullable)
Creates a consumer for
IntVector. |
static JdbcConsumer<TimeMilliVector> |
TimeConsumer.createConsumer(TimeMilliVector vector,
int index,
boolean nullable,
Calendar calendar)
Creates a consumer for
TimeMilliVector. |
static JdbcConsumer<TimeStampMilliTZVector> |
TimestampTZConsumer.createConsumer(TimeStampMilliTZVector vector,
int index,
boolean nullable,
Calendar calendar)
Creates a consumer for
TimeStampMilliTZVector. |
static JdbcConsumer<TimeStampMilliVector> |
TimestampConsumer.createConsumer(TimeStampMilliVector vector,
int index,
boolean nullable)
Creates a consumer for
TimeStampMilliVector. |
static JdbcConsumer<TinyIntVector> |
TinyIntConsumer.createConsumer(TinyIntVector vector,
int index,
boolean nullable)
Creates a consumer for
TinyIntVector. |
static JdbcConsumer<VarCharVector> |
VarCharConsumer.createConsumer(VarCharVector vector,
int index,
boolean nullable)
Creates a consumer for
VarCharVector. |
| Modifier and Type | Method and Description |
|---|---|
static ArrayConsumer |
ArrayConsumer.createConsumer(ListVector vector,
JdbcConsumer delegate,
int index,
boolean nullable)
Creates a consumer for
ListVector. |
| Constructor and Description |
|---|
ArrayConsumer(ListVector vector,
JdbcConsumer delegate,
int index)
Instantiate a ArrayConsumer.
|
CompositeJdbcConsumer(JdbcConsumer[] consumers)
Construct an instance.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.