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.