Package org.apache.arrow.adapter.jdbc.consumer

Class Decimal256Consumer

java.lang.Object

org.apache.arrow.adapter.jdbc.consumer.BaseConsumer<Decimal256Vector>

org.apache.arrow.adapter.jdbc.consumer.Decimal256Consumer

All Implemented Interfaces:

AutoCloseable, JdbcConsumer<Decimal256Vector>

public abstract class Decimal256Consumer
extends BaseConsumer<Decimal256Vector>

Consumer which consume decimal type values from ResultSet. Write the data to Decimal256Vector.

Field Summary

Fields inherited from class org.apache.arrow.adapter.jdbc.consumer.BaseConsumer

columnIndexInResultSet, currentIndex, vector

Constructor Summary

Constructors

Constructor	Description
Decimal256Consumer(Decimal256Vector vector, int index)	Constructs a new consumer.
Decimal256Consumer(Decimal256Vector vector, int index, RoundingMode bigDecimalRoundingMode)	Constructs a new consumer, with optional coercibility.

Method Summary

Modifier and Type	Method	Description
static JdbcConsumer<Decimal256Vector>	createConsumer(Decimal256Vector vector, int index, boolean nullable, RoundingMode bigDecimalRoundingMode)	Creates a consumer for Decimal256Vector.
protected void	set(BigDecimal value)

Methods inherited from class org.apache.arrow.adapter.jdbc.consumer.BaseConsumer

close, resetValueVector

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.arrow.adapter.jdbc.consumer.JdbcConsumer

consume

Constructor Details

Decimal256Consumer

public Decimal256Consumer(Decimal256Vector vector,
 int index)

Constructs a new consumer.

Parameters:

vector - the underlying vector for the consumer.

index - the column id for the consumer.

Decimal256Consumer

public Decimal256Consumer(Decimal256Vector vector,
 int index,
 RoundingMode bigDecimalRoundingMode)

Constructs a new consumer, with optional coercibility.

Parameters:

vector - the underlying vector for the consumer.

index - the column index for the consumer.

bigDecimalRoundingMode - java.math.RoundingMode to be applied if the BigDecimal scale does not match that of the target vector. Set to null to retain strict matching behavior (scale of source and target vector must match exactly).

Method Details

createConsumer

public static JdbcConsumer<Decimal256Vector> createConsumer(Decimal256Vector vector,
 int index,
 boolean nullable,
 RoundingMode bigDecimalRoundingMode)

Creates a consumer for Decimal256Vector.

set

protected void set(BigDecimal value)