> getColumnMetadataByColumnIndex() {
return columnMetadataByColumnIndex;
}
@@ -383,12 +394,14 @@ public RoundingMode getBigDecimalRoundingMode() {
return bigDecimalRoundingMode;
}
- /**
- * Interface for a function that gets a JDBC consumer for the given values.
- */
+ /** Interface for a function that gets a JDBC consumer for the given values. */
@FunctionalInterface
public interface JdbcConsumerFactory {
- JdbcConsumer apply(ArrowType arrowType, int columnIndex, boolean nullable, FieldVector vector,
- JdbcToArrowConfig config);
+ JdbcConsumer apply(
+ ArrowType arrowType,
+ int columnIndex,
+ boolean nullable,
+ FieldVector vector,
+ JdbcToArrowConfig config);
}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfigBuilder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfigBuilder.java
index 7d88c238320..cef26b27b7a 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfigBuilder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfigBuilder.java
@@ -23,15 +23,12 @@
import java.util.Calendar;
import java.util.Map;
import java.util.function.Function;
-
import org.apache.arrow.memory.BufferAllocator;
import org.apache.arrow.util.Preconditions;
import org.apache.arrow.vector.FieldVector;
import org.apache.arrow.vector.types.pojo.ArrowType;
-/**
- * This class builds {@link JdbcToArrowConfig}s.
- */
+/** This class builds {@link JdbcToArrowConfig}s. */
public class JdbcToArrowConfigBuilder {
private Calendar calendar;
private BufferAllocator allocator;
@@ -49,9 +46,9 @@ public class JdbcToArrowConfigBuilder {
private RoundingMode bigDecimalRoundingMode;
/**
- * Default constructor for the JdbcToArrowConfigBuilder}.
- * Use the setter methods for the allocator and calendar; the allocator must be
- * set. Otherwise, {@link #build()} will throw a {@link NullPointerException}.
+ * Default constructor for the JdbcToArrowConfigBuilder}. Use the setter methods for
+ * the allocator and calendar; the allocator must be set. Otherwise, {@link #build()} will throw a
+ * {@link NullPointerException}.
*/
public JdbcToArrowConfigBuilder() {
this.allocator = null;
@@ -68,16 +65,13 @@ public JdbcToArrowConfigBuilder() {
}
/**
- * Constructor for the JdbcToArrowConfigBuilder. The
- * allocator is required, and a {@link NullPointerException}
- * will be thrown if it is null.
- *
- * The allocator is used to construct Arrow vectors from the JDBC ResultSet.
- * The calendar is used to determine the time zone of {@link java.sql.Timestamp}
- * fields and convert {@link java.sql.Date}, {@link java.sql.Time}, and
- * {@link java.sql.Timestamp} fields to a single, common time zone when reading
- * from the result set.
- *
+ * Constructor for the JdbcToArrowConfigBuilder. The allocator is required, and a
+ * {@link NullPointerException} will be thrown if it is null.
+ *
+ * The allocator is used to construct Arrow vectors from the JDBC ResultSet. The calendar is
+ * used to determine the time zone of {@link java.sql.Timestamp} fields and convert {@link
+ * java.sql.Date}, {@link java.sql.Time}, and {@link java.sql.Timestamp} fields to a single,
+ * common time zone when reading from the result set.
*
* @param allocator The Arrow Vector memory allocator.
* @param calendar The calendar to use when constructing timestamp fields.
@@ -95,26 +89,23 @@ public JdbcToArrowConfigBuilder(BufferAllocator allocator, Calendar calendar) {
}
/**
- * Constructor for the JdbcToArrowConfigBuilder. Both the
- * allocator and calendar are required. A {@link NullPointerException}
- * will be thrown if either of those arguments is null.
- *
- * The allocator is used to construct Arrow vectors from the JDBC ResultSet.
- * The calendar is used to determine the time zone of {@link java.sql.Timestamp}
- * fields and convert {@link java.sql.Date}, {@link java.sql.Time}, and
- * {@link java.sql.Timestamp} fields to a single, common time zone when reading
- * from the result set.
- *
- *
- * The includeMetadata argument, if true will cause
- * various information about each database field to be added to the Vector
- * Schema's field metadata.
- *
+ * Constructor for the JdbcToArrowConfigBuilder. Both the allocator and calendar are
+ * required. A {@link NullPointerException} will be thrown if either of those arguments is
+ * null.
+ *
+ * The allocator is used to construct Arrow vectors from the JDBC ResultSet. The calendar is
+ * used to determine the time zone of {@link java.sql.Timestamp} fields and convert {@link
+ * java.sql.Date}, {@link java.sql.Time}, and {@link java.sql.Timestamp} fields to a single,
+ * common time zone when reading from the result set.
+ *
+ *
The includeMetadata argument, if true will cause various
+ * information about each database field to be added to the Vector Schema's field metadata.
*
* @param allocator The Arrow Vector memory allocator.
* @param calendar The calendar to use when constructing timestamp fields.
*/
- public JdbcToArrowConfigBuilder(BufferAllocator allocator, Calendar calendar, boolean includeMetadata) {
+ public JdbcToArrowConfigBuilder(
+ BufferAllocator allocator, Calendar calendar, boolean includeMetadata) {
this(allocator, calendar);
this.includeMetadata = includeMetadata;
}
@@ -132,8 +123,8 @@ public JdbcToArrowConfigBuilder setAllocator(BufferAllocator allocator) {
}
/**
- * Sets the {@link Calendar} to use when constructing timestamp fields in the
- * Arrow schema, and reading time-based fields from the JDBC ResultSet.
+ * Sets the {@link Calendar} to use when constructing timestamp fields in the Arrow schema, and
+ * reading time-based fields from the JDBC ResultSet.
*
* @param calendar the calendar to set.
*/
@@ -145,7 +136,8 @@ public JdbcToArrowConfigBuilder setCalendar(Calendar calendar) {
/**
* Sets whether to include JDBC ResultSet field metadata in the Arrow Schema field metadata.
*
- * @param includeMetadata Whether to include or exclude JDBC metadata in the Arrow Schema field metadata.
+ * @param includeMetadata Whether to include or exclude JDBC metadata in the Arrow Schema field
+ * metadata.
* @return This instance of the JdbcToArrowConfig, for chaining.
*/
public JdbcToArrowConfigBuilder setIncludeMetadata(boolean includeMetadata) {
@@ -154,8 +146,8 @@ public JdbcToArrowConfigBuilder setIncludeMetadata(boolean includeMetadata) {
}
/**
- * Sets the mapping of column-index-to-{@link JdbcFieldInfo} used for columns of type {@link java.sql.Types#ARRAY}.
- * The column index is 1-based, to match the JDBC column index.
+ * Sets the mapping of column-index-to-{@link JdbcFieldInfo} used for columns of type {@link
+ * java.sql.Types#ARRAY}. The column index is 1-based, to match the JDBC column index.
*
* @param map The mapping.
* @return This instance of the JdbcToArrowConfig, for chaining.
@@ -166,7 +158,8 @@ public JdbcToArrowConfigBuilder setArraySubTypeByColumnIndexMap(MapJdbcToArrowConfig, for chaining.
@@ -178,11 +171,12 @@ public JdbcToArrowConfigBuilder setArraySubTypeByColumnNameMap(Map
- * This can be useful to override type information from JDBC drivers that provide incomplete type info,
- * e.g. DECIMAL with precision = scale = 0.
- *
- * The column index is 1-based, to match the JDBC column index.
+ *
+ *
This can be useful to override type information from JDBC drivers that provide incomplete
+ * type info, e.g. DECIMAL with precision = scale = 0.
+ *
+ *
The column index is 1-based, to match the JDBC column index.
+ *
* @param map The mapping.
*/
public JdbcToArrowConfigBuilder setExplicitTypesByColumnIndex(Map map) {
@@ -192,9 +186,10 @@ public JdbcToArrowConfigBuilder setExplicitTypesByColumnIndex(Map
- * This can be useful to override type information from JDBC drivers that provide incomplete type info,
- * e.g. DECIMAL with precision = scale = 0.
+ *
+ * This can be useful to override type information from JDBC drivers that provide incomplete
+ * type info, e.g. DECIMAL with precision = scale = 0.
+ *
* @param map The mapping.
*/
public JdbcToArrowConfigBuilder setExplicitTypesByColumnName(Map map) {
@@ -204,8 +199,8 @@ public JdbcToArrowConfigBuilder setExplicitTypesByColumnName(Map
- * Use {@link JdbcToArrowConfig#NO_LIMIT_BATCH_SIZE} to read all rows at once.
+ *
+ * Use {@link JdbcToArrowConfig#NO_LIMIT_BATCH_SIZE} to read all rows at once.
*/
public JdbcToArrowConfigBuilder setTargetBatchSize(int targetBatchSize) {
this.targetBatchSize = targetBatchSize;
@@ -214,8 +209,9 @@ public JdbcToArrowConfigBuilder setTargetBatchSize(int targetBatchSize) {
/**
* Set the function used to convert JDBC types to Arrow types.
- *
- * Defaults to wrapping {@link JdbcToArrowUtils#getArrowTypeFromJdbcType(JdbcFieldInfo, Calendar)}.
+ *
+ *
Defaults to wrapping {@link JdbcToArrowUtils#getArrowTypeFromJdbcType(JdbcFieldInfo,
+ * Calendar)}.
*/
public JdbcToArrowConfigBuilder setJdbcToArrowTypeConverter(
Function jdbcToArrowTypeConverter) {
@@ -225,9 +221,9 @@ public JdbcToArrowConfigBuilder setJdbcToArrowTypeConverter(
/**
* Set the function used to get a JDBC consumer for a given type.
- *
- * Defaults to wrapping {@link
- * JdbcToArrowUtils#getConsumer(ArrowType, Integer, Boolean, FieldVector, JdbcToArrowConfig)}.
+ *
+ *
Defaults to wrapping {@link JdbcToArrowUtils#getConsumer(ArrowType, Integer, Boolean,
+ * FieldVector, JdbcToArrowConfig)}.
*/
public JdbcToArrowConfigBuilder setJdbcConsumerGetter(
JdbcToArrowConfig.JdbcConsumerFactory jdbcConsumerGetter) {
@@ -236,35 +232,32 @@ public JdbcToArrowConfigBuilder setJdbcConsumerGetter(
}
/**
- * Set whether to use the same {@link org.apache.arrow.vector.VectorSchemaRoot} instance on each iteration,
- * or to allocate a new one.
+ * Set whether to use the same {@link org.apache.arrow.vector.VectorSchemaRoot} instance on each
+ * iteration, or to allocate a new one.
*/
public JdbcToArrowConfigBuilder setReuseVectorSchemaRoot(boolean reuseVectorSchemaRoot) {
this.reuseVectorSchemaRoot = reuseVectorSchemaRoot;
return this;
}
- /**
- * Set metadata for schema.
- */
+ /** Set metadata for schema. */
public JdbcToArrowConfigBuilder setSchemaMetadata(Map schemaMetadata) {
this.schemaMetadata = schemaMetadata;
return this;
}
- /**
- * Set metadata from columnIndex->meta map on per field basis.
- */
+ /** Set metadata from columnIndex->meta map on per field basis. */
public JdbcToArrowConfigBuilder setColumnMetadataByColumnIndex(
- Map> columnMetadataByColumnIndex) {
+ Map> columnMetadataByColumnIndex) {
this.columnMetadataByColumnIndex = columnMetadataByColumnIndex;
return this;
}
/**
- * Set the rounding mode used when the scale of the actual value does not match the declared scale.
- *
- * By default, an error is raised in such cases.
+ * Set the rounding mode used when the scale of the actual value does not match the declared
+ * scale.
+ *
+ *
By default, an error is raised in such cases.
*/
public JdbcToArrowConfigBuilder setBigDecimalRoundingMode(RoundingMode bigDecimalRoundingMode) {
this.bigDecimalRoundingMode = bigDecimalRoundingMode;
@@ -272,8 +265,8 @@ public JdbcToArrowConfigBuilder setBigDecimalRoundingMode(RoundingMode bigDecima
}
/**
- * This builds the {@link JdbcToArrowConfig} from the provided
- * {@link BufferAllocator} and {@link Calendar}.
+ * This builds the {@link JdbcToArrowConfig} from the provided {@link BufferAllocator} and {@link
+ * Calendar}.
*
* @return The built {@link JdbcToArrowConfig}
* @throws NullPointerException if either the allocator or calendar was not set.
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowUtils.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowUtils.java
index eaee4993607..959083136a7 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowUtils.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowUtils.java
@@ -38,7 +38,6 @@
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
-
import org.apache.arrow.adapter.jdbc.consumer.ArrayConsumer;
import org.apache.arrow.adapter.jdbc.consumer.BigIntConsumer;
import org.apache.arrow.adapter.jdbc.consumer.BinaryConsumer;
@@ -91,7 +90,8 @@
import org.apache.arrow.vector.util.ValueVectorUtility;
/**
- * Class that does most of the work to convert JDBC ResultSet data into Arrow columnar format Vector objects.
+ * Class that does most of the work to convert JDBC ResultSet data into Arrow columnar format Vector
+ * objects.
*
* @since 0.10.0
*/
@@ -99,9 +99,7 @@ public class JdbcToArrowUtils {
private static final int JDBC_ARRAY_VALUE_COLUMN = 2;
- /**
- * Returns the instance of a {java.util.Calendar} with the UTC time zone and root locale.
- */
+ /** Returns the instance of a {java.util.Calendar} with the UTC time zone and root locale. */
public static Calendar getUtcCalendar() {
return Calendar.getInstance(TimeZone.getTimeZone("UTC"), Locale.ROOT);
}
@@ -114,7 +112,8 @@ public static Calendar getUtcCalendar() {
* @return {@link Schema}
* @throws SQLException on error
*/
- public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, Calendar calendar) throws SQLException {
+ public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, Calendar calendar)
+ throws SQLException {
Preconditions.checkNotNull(calendar, "Calendar object can't be null");
return jdbcToArrowSchema(rsmd, new JdbcToArrowConfig(new RootAllocator(0), calendar));
@@ -123,25 +122,28 @@ public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, Calendar calendar
/**
* Create Arrow {@link Schema} object for the given JDBC {@link ResultSetMetaData}.
*
- * @param parameterMetaData The ResultSetMetaData containing the results, to read the JDBC metadata from.
- * @param calendar The calendar to use the time zone field of, to construct Timestamp fields from.
+ * @param parameterMetaData The ResultSetMetaData containing the results, to read the JDBC
+ * metadata from.
+ * @param calendar The calendar to use the time zone field of, to construct Timestamp fields from.
* @return {@link Schema}
* @throws SQLException on error
*/
- public static Schema jdbcToArrowSchema(final ParameterMetaData parameterMetaData, final Calendar calendar)
- throws SQLException {
+ public static Schema jdbcToArrowSchema(
+ final ParameterMetaData parameterMetaData, final Calendar calendar) throws SQLException {
Preconditions.checkNotNull(calendar, "Calendar object can't be null");
Preconditions.checkNotNull(parameterMetaData);
final List parameterFields = new ArrayList<>(parameterMetaData.getParameterCount());
- for (int parameterCounter = 1; parameterCounter <= parameterMetaData.getParameterCount();
- parameterCounter++) {
+ for (int parameterCounter = 1;
+ parameterCounter <= parameterMetaData.getParameterCount();
+ parameterCounter++) {
final int jdbcDataType = parameterMetaData.getParameterType(parameterCounter);
final int jdbcIsNullable = parameterMetaData.isNullable(parameterCounter);
final boolean arrowIsNullable = jdbcIsNullable != ParameterMetaData.parameterNoNulls;
final int precision = parameterMetaData.getPrecision(parameterCounter);
final int scale = parameterMetaData.getScale(parameterCounter);
- final ArrowType arrowType = getArrowTypeFromJdbcType(new JdbcFieldInfo(jdbcDataType, precision, scale), calendar);
- final FieldType fieldType = new FieldType(arrowIsNullable, arrowType, /*dictionary=*/null);
+ final ArrowType arrowType =
+ getArrowTypeFromJdbcType(new JdbcFieldInfo(jdbcDataType, precision, scale), calendar);
+ final FieldType fieldType = new FieldType(arrowIsNullable, arrowType, /* dictionary= */ null);
parameterFields.add(new Field(null, fieldType, null));
}
@@ -152,10 +154,11 @@ public static Schema jdbcToArrowSchema(final ParameterMetaData parameterMetaData
* Converts the provided JDBC type to its respective {@link ArrowType} counterpart.
*
* @param fieldInfo the {@link JdbcFieldInfo} with information about the original JDBC type.
- * @param calendar the {@link Calendar} to use for datetime data types.
+ * @param calendar the {@link Calendar} to use for datetime data types.
* @return a new {@link ArrowType}.
*/
- public static ArrowType getArrowTypeFromJdbcType(final JdbcFieldInfo fieldInfo, final Calendar calendar) {
+ public static ArrowType getArrowTypeFromJdbcType(
+ final JdbcFieldInfo fieldInfo, final Calendar calendar) {
switch (fieldInfo.getJdbcType()) {
case Types.BOOLEAN:
case Types.BIT:
@@ -222,30 +225,34 @@ public static ArrowType getArrowTypeFromJdbcType(final JdbcFieldInfo fieldInfo,
/**
* Create Arrow {@link Schema} object for the given JDBC {@link java.sql.ResultSetMetaData}.
*
- *
- * If {@link JdbcToArrowConfig#shouldIncludeMetadata()} returns true, the following fields
- * will be added to the {@link FieldType#getMetadata()}:
+ *
If {@link JdbcToArrowConfig#shouldIncludeMetadata()} returns true, the
+ * following fields will be added to the {@link FieldType#getMetadata()}:
+ *
*
- * - {@link Constants#SQL_CATALOG_NAME_KEY} representing {@link ResultSetMetaData#getCatalogName(int)}
- * - {@link Constants#SQL_TABLE_NAME_KEY} representing {@link ResultSetMetaData#getTableName(int)}
- * - {@link Constants#SQL_COLUMN_NAME_KEY} representing {@link ResultSetMetaData#getColumnLabel(int)}
- * - {@link Constants#SQL_TYPE_KEY} representing {@link ResultSetMetaData#getColumnTypeName(int)}
+ * - {@link Constants#SQL_CATALOG_NAME_KEY} representing {@link
+ * ResultSetMetaData#getCatalogName(int)}
+ *
- {@link Constants#SQL_TABLE_NAME_KEY} representing {@link
+ * ResultSetMetaData#getTableName(int)}
+ *
- {@link Constants#SQL_COLUMN_NAME_KEY} representing {@link
+ * ResultSetMetaData#getColumnLabel(int)}
+ *
- {@link Constants#SQL_TYPE_KEY} representing {@link
+ * ResultSetMetaData#getColumnTypeName(int)}
*
- *
- *
- * If any columns are of type {@link java.sql.Types#ARRAY}, the configuration object will be used to look up
- * the array sub-type field. The {@link JdbcToArrowConfig#getArraySubTypeByColumnIndex(int)} method will be
- * checked first, followed by the {@link JdbcToArrowConfig#getArraySubTypeByColumnName(String)} method.
- *
+ *
+ * If any columns are of type {@link java.sql.Types#ARRAY}, the configuration object will be
+ * used to look up the array sub-type field. The {@link
+ * JdbcToArrowConfig#getArraySubTypeByColumnIndex(int)} method will be checked first, followed by
+ * the {@link JdbcToArrowConfig#getArraySubTypeByColumnName(String)} method.
*
* @param rsmd The ResultSetMetaData containing the results, to read the JDBC metadata from.
* @param config The configuration to use when constructing the schema.
* @return {@link Schema}
* @throws SQLException on error
- * @throws IllegalArgumentException if rsmd contains an {@link java.sql.Types#ARRAY} but the
- * config does not have a sub-type definition for it.
+ * @throws IllegalArgumentException if rsmd contains an {@link java.sql.Types#ARRAY}
+ * but the config does not have a sub-type definition for it.
*/
- public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, JdbcToArrowConfig config) throws SQLException {
+ public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, JdbcToArrowConfig config)
+ throws SQLException {
Preconditions.checkNotNull(rsmd, "JDBC ResultSetMetaData object can't be null");
Preconditions.checkNotNull(config, "The configuration object must not be null");
@@ -254,8 +261,10 @@ public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, JdbcToArrowConfig
for (int i = 1; i <= columnCount; i++) {
final String columnName = rsmd.getColumnLabel(i);
- final Map columnMetadata = config.getColumnMetadataByColumnIndex() != null ?
- config.getColumnMetadataByColumnIndex().get(i) : null;
+ final Map columnMetadata =
+ config.getColumnMetadataByColumnIndex() != null
+ ? config.getColumnMetadataByColumnIndex().get(i)
+ : null;
final Map metadata;
if (config.shouldIncludeMetadata()) {
metadata = new HashMap<>();
@@ -278,14 +287,19 @@ public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, JdbcToArrowConfig
final JdbcFieldInfo columnFieldInfo = getJdbcFieldInfoForColumn(rsmd, i, config);
final ArrowType arrowType = config.getJdbcToArrowTypeConverter().apply(columnFieldInfo);
if (arrowType != null) {
- final FieldType fieldType = new FieldType(
- isColumnNullable(rsmd, i, columnFieldInfo), arrowType, /* dictionary encoding */ null, metadata);
+ final FieldType fieldType =
+ new FieldType(
+ isColumnNullable(rsmd, i, columnFieldInfo),
+ arrowType, /* dictionary encoding */
+ null,
+ metadata);
List children = null;
if (arrowType.getTypeID() == ArrowType.List.TYPE_TYPE) {
final JdbcFieldInfo arrayFieldInfo = getJdbcFieldInfoForArraySubType(rsmd, i, config);
if (arrayFieldInfo == null) {
- throw new IllegalArgumentException("Configuration does not provide a mapping for array column " + i);
+ throw new IllegalArgumentException(
+ "Configuration does not provide a mapping for array column " + i);
}
children = new ArrayList();
final ArrowType childType = config.getJdbcToArrowTypeConverter().apply(arrayFieldInfo);
@@ -295,9 +309,13 @@ public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, JdbcToArrowConfig
FieldType keyType = new FieldType(false, new ArrowType.Utf8(), null, null);
FieldType valueType = new FieldType(false, new ArrowType.Utf8(), null, null);
children = new ArrayList<>();
- children.add(new Field("child", mapType,
- Arrays.asList(new Field(MapVector.KEY_NAME, keyType, null),
- new Field(MapVector.VALUE_NAME, valueType, null))));
+ children.add(
+ new Field(
+ "child",
+ mapType,
+ Arrays.asList(
+ new Field(MapVector.KEY_NAME, keyType, null),
+ new Field(MapVector.VALUE_NAME, valueType, null))));
}
fields.add(new Field(columnName, fieldType, children));
@@ -307,18 +325,14 @@ public static Schema jdbcToArrowSchema(ResultSetMetaData rsmd, JdbcToArrowConfig
}
static JdbcFieldInfo getJdbcFieldInfoForColumn(
- ResultSetMetaData rsmd,
- int arrayColumn,
- JdbcToArrowConfig config)
- throws SQLException {
+ ResultSetMetaData rsmd, int arrayColumn, JdbcToArrowConfig config) throws SQLException {
Preconditions.checkNotNull(rsmd, "ResultSet MetaData object cannot be null");
Preconditions.checkNotNull(config, "Configuration must not be null");
Preconditions.checkArgument(
- arrayColumn > 0,
- "ResultSetMetaData columns start with 1; column cannot be less than 1");
+ arrayColumn > 0, "ResultSetMetaData columns start with 1; column cannot be less than 1");
Preconditions.checkArgument(
- arrayColumn <= rsmd.getColumnCount(),
- "Column number cannot be more than the number of columns");
+ arrayColumn <= rsmd.getColumnCount(),
+ "Column number cannot be more than the number of columns");
JdbcFieldInfo fieldInfo = config.getExplicitTypeByColumnIndex(arrayColumn);
if (fieldInfo == null) {
@@ -334,16 +348,12 @@ static JdbcFieldInfo getJdbcFieldInfoForColumn(
* If no sub-type can be found, returns null.
*/
private static JdbcFieldInfo getJdbcFieldInfoForArraySubType(
- ResultSetMetaData rsmd,
- int arrayColumn,
- JdbcToArrowConfig config)
- throws SQLException {
+ ResultSetMetaData rsmd, int arrayColumn, JdbcToArrowConfig config) throws SQLException {
Preconditions.checkNotNull(rsmd, "ResultSet MetaData object cannot be null");
Preconditions.checkNotNull(config, "Configuration must not be null");
Preconditions.checkArgument(
- arrayColumn > 0,
- "ResultSetMetaData columns start with 1; column cannot be less than 1");
+ arrayColumn > 0, "ResultSetMetaData columns start with 1; column cannot be less than 1");
Preconditions.checkArgument(
arrayColumn <= rsmd.getColumnCount(),
"Column number cannot be more than the number of columns");
@@ -359,10 +369,10 @@ private static JdbcFieldInfo getJdbcFieldInfoForArraySubType(
* Iterate the given JDBC {@link ResultSet} object to fetch the data and transpose it to populate
* the given Arrow Vector objects.
*
- * @param rs ResultSet to use to fetch the data from underlying database
- * @param root Arrow {@link VectorSchemaRoot} object to populate
- * @param calendar The calendar to use when reading {@link Date}, {@link Time}, or {@link Timestamp}
- * data types from the {@link ResultSet}, or null if not converting.
+ * @param rs ResultSet to use to fetch the data from underlying database
+ * @param root Arrow {@link VectorSchemaRoot} object to populate
+ * @param calendar The calendar to use when reading {@link Date}, {@link Time}, or {@link
+ * Timestamp} data types from the {@link ResultSet}, or null if not converting.
* @throws SQLException on error
*/
public static void jdbcToArrowVectors(ResultSet rs, VectorSchemaRoot root, Calendar calendar)
@@ -373,29 +383,30 @@ public static void jdbcToArrowVectors(ResultSet rs, VectorSchemaRoot root, Calen
jdbcToArrowVectors(rs, root, new JdbcToArrowConfig(new RootAllocator(0), calendar));
}
- static boolean isColumnNullable(ResultSetMetaData resultSetMetadata, int index, JdbcFieldInfo info)
- throws SQLException {
+ static boolean isColumnNullable(
+ ResultSetMetaData resultSetMetadata, int index, JdbcFieldInfo info) throws SQLException {
int nullableValue;
if (info != null && info.isNullable() != ResultSetMetaData.columnNullableUnknown) {
nullableValue = info.isNullable();
} else {
nullableValue = resultSetMetadata.isNullable(index);
}
- return nullableValue == ResultSetMetaData.columnNullable ||
- nullableValue == ResultSetMetaData.columnNullableUnknown;
+ return nullableValue == ResultSetMetaData.columnNullable
+ || nullableValue == ResultSetMetaData.columnNullableUnknown;
}
/**
* Iterate the given JDBC {@link ResultSet} object to fetch the data and transpose it to populate
* the given Arrow Vector objects.
*
- * @param rs ResultSet to use to fetch the data from underlying database
- * @param root Arrow {@link VectorSchemaRoot} object to populate
+ * @param rs ResultSet to use to fetch the data from underlying database
+ * @param root Arrow {@link VectorSchemaRoot} object to populate
* @param config The configuration to use when reading the data.
* @throws SQLException on error
* @throws JdbcConsumerException on error from VectorConsumer
*/
- public static void jdbcToArrowVectors(ResultSet rs, VectorSchemaRoot root, JdbcToArrowConfig config)
+ public static void jdbcToArrowVectors(
+ ResultSet rs, VectorSchemaRoot root, JdbcToArrowConfig config)
throws SQLException, IOException {
ResultSetMetaData rsmd = rs.getMetaData();
@@ -405,8 +416,13 @@ public static void jdbcToArrowVectors(ResultSet rs, VectorSchemaRoot root, JdbcT
for (int i = 1; i <= columnCount; i++) {
FieldVector vector = root.getVector(rsmd.getColumnLabel(i));
final JdbcFieldInfo columnFieldInfo = getJdbcFieldInfoForColumn(rsmd, i, config);
- consumers[i - 1] = getConsumer(
- vector.getField().getType(), i, isColumnNullable(rsmd, i, columnFieldInfo), vector, config);
+ consumers[i - 1] =
+ getConsumer(
+ vector.getField().getType(),
+ i,
+ isColumnNullable(rsmd, i, columnFieldInfo),
+ vector,
+ config);
}
CompositeJdbcConsumer compositeConsumer = null;
@@ -439,18 +455,22 @@ public static void jdbcToArrowVectors(ResultSet rs, VectorSchemaRoot root, JdbcT
}
/**
- * Default function used for JdbcConsumerFactory. This function gets a JdbcConsumer for the
- * given column based on the Arrow type and provided vector.
+ * Default function used for JdbcConsumerFactory. This function gets a JdbcConsumer for the given
+ * column based on the Arrow type and provided vector.
*
- * @param arrowType Arrow type for the column.
+ * @param arrowType Arrow type for the column.
* @param columnIndex Column index to fetch from the ResultSet
- * @param nullable Whether the value is nullable or not
- * @param vector Vector to store the consumed value
- * @param config Associated JdbcToArrowConfig, used mainly for the Calendar.
+ * @param nullable Whether the value is nullable or not
+ * @param vector Vector to store the consumed value
+ * @param config Associated JdbcToArrowConfig, used mainly for the Calendar.
* @return {@link JdbcConsumer}
*/
- public static JdbcConsumer getConsumer(ArrowType arrowType, int columnIndex, boolean nullable,
- FieldVector vector, JdbcToArrowConfig config) {
+ public static JdbcConsumer getConsumer(
+ ArrowType arrowType,
+ int columnIndex,
+ boolean nullable,
+ FieldVector vector,
+ JdbcToArrowConfig config) {
final Calendar calendar = config.getCalendar();
switch (arrowType.getTypeID()) {
@@ -472,10 +492,11 @@ public static JdbcConsumer getConsumer(ArrowType arrowType, int columnIndex, boo
case Decimal:
final RoundingMode bigDecimalRoundingMode = config.getBigDecimalRoundingMode();
if (((ArrowType.Decimal) arrowType).getBitWidth() == 256) {
- return Decimal256Consumer.createConsumer((Decimal256Vector) vector, columnIndex, nullable,
- bigDecimalRoundingMode);
+ return Decimal256Consumer.createConsumer(
+ (Decimal256Vector) vector, columnIndex, nullable, bigDecimalRoundingMode);
} else {
- return DecimalConsumer.createConsumer((DecimalVector) vector, columnIndex, nullable, bigDecimalRoundingMode);
+ return DecimalConsumer.createConsumer(
+ (DecimalVector) vector, columnIndex, nullable, bigDecimalRoundingMode);
}
case FloatingPoint:
switch (((ArrowType.FloatingPoint) arrowType).getPrecision()) {
@@ -495,17 +516,25 @@ public static JdbcConsumer getConsumer(ArrowType arrowType, int columnIndex, boo
case Date:
return DateConsumer.createConsumer((DateDayVector) vector, columnIndex, nullable, calendar);
case Time:
- return TimeConsumer.createConsumer((TimeMilliVector) vector, columnIndex, nullable, calendar);
+ return TimeConsumer.createConsumer(
+ (TimeMilliVector) vector, columnIndex, nullable, calendar);
case Timestamp:
if (config.getCalendar() == null) {
- return TimestampConsumer.createConsumer((TimeStampMilliVector) vector, columnIndex, nullable);
+ return TimestampConsumer.createConsumer(
+ (TimeStampMilliVector) vector, columnIndex, nullable);
} else {
- return TimestampTZConsumer.createConsumer((TimeStampMilliTZVector) vector, columnIndex, nullable, calendar);
+ return TimestampTZConsumer.createConsumer(
+ (TimeStampMilliTZVector) vector, columnIndex, nullable, calendar);
}
case List:
FieldVector childVector = ((ListVector) vector).getDataVector();
- JdbcConsumer delegate = getConsumer(childVector.getField().getType(), JDBC_ARRAY_VALUE_COLUMN,
- childVector.getField().isNullable(), childVector, config);
+ JdbcConsumer delegate =
+ getConsumer(
+ childVector.getField().getType(),
+ JDBC_ARRAY_VALUE_COLUMN,
+ childVector.getField().isNullable(),
+ childVector,
+ config);
return ArrayConsumer.createConsumer((ListVector) vector, delegate, columnIndex, nullable);
case Map:
return MapConsumer.createConsumer((MapVector) vector, columnIndex, nullable);
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BaseColumnBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BaseColumnBinder.java
index f24f409072c..e1df0041982 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BaseColumnBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BaseColumnBinder.java
@@ -21,6 +21,7 @@
/**
* Base class for ColumnBinder implementations.
+ *
* @param The concrete FieldVector subtype.
*/
public abstract class BaseColumnBinder implements ColumnBinder {
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BigIntBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BigIntBinder.java
index fde4642ef90..f84a7c3e22b 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BigIntBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BigIntBinder.java
@@ -20,7 +20,6 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.BigIntVector;
/** A column binder for 8-bit integers. */
@@ -34,7 +33,8 @@ public BigIntBinder(BigIntVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
final long value = vector.getDataBuffer().getLong((long) rowIndex * BigIntVector.TYPE_WIDTH);
statement.setLong(parameterIndex, value);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BitBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BitBinder.java
index adae513e99e..86930dc35cb 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BitBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/BitBinder.java
@@ -20,7 +20,6 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.BitVector;
/** A column binder for booleans. */
@@ -34,7 +33,8 @@ public BitBinder(BitVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
// See BitVector#getBit
final int byteIndex = rowIndex >> 3;
final byte b = vector.getDataBuffer().getByte(byteIndex);
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinder.java
index c2b1259e142..0e16b61ef84 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinder.java
@@ -19,12 +19,9 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
-
import org.apache.arrow.vector.FieldVector;
-/**
- * A helper to bind values from a wrapped Arrow vector to a JDBC PreparedStatement.
- */
+/** A helper to bind values from a wrapped Arrow vector to a JDBC PreparedStatement. */
public interface ColumnBinder {
/**
* Bind the given row to the given parameter.
@@ -43,14 +40,10 @@ public interface ColumnBinder {
*/
int getJdbcType();
- /**
- * Get the vector used by this binder.
- */
+ /** Get the vector used by this binder. */
FieldVector getVector();
- /**
- * Create a column binder for a vector, using the default JDBC type code for null values.
- */
+ /** Create a column binder for a vector, using the default JDBC type code for null values. */
static ColumnBinder forVector(FieldVector vector) {
return forVector(vector, /*jdbcType*/ null);
}
@@ -62,7 +55,8 @@ static ColumnBinder forVector(FieldVector vector) {
* @param jdbcType The JDBC type code to use (or null to use the default).
*/
static ColumnBinder forVector(FieldVector vector, Integer jdbcType) {
- final ColumnBinder binder = vector.getField().getType().accept(new ColumnBinderArrowTypeVisitor(vector, jdbcType));
+ final ColumnBinder binder =
+ vector.getField().getType().accept(new ColumnBinderArrowTypeVisitor(vector, jdbcType));
if (vector.getField().isNullable()) {
return new NullableColumnBinder(binder);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinderArrowTypeVisitor.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinderArrowTypeVisitor.java
index dc708724043..8dd43f25b66 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinderArrowTypeVisitor.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ColumnBinderArrowTypeVisitor.java
@@ -21,7 +21,6 @@
import java.time.ZoneId;
import java.util.Calendar;
import java.util.TimeZone;
-
import org.apache.arrow.vector.BigIntVector;
import org.apache.arrow.vector.BitVector;
import org.apache.arrow.vector.DateDayVector;
@@ -50,8 +49,8 @@
/**
* Visitor to create the base ColumnBinder for a vector.
- *
- * To handle null values, wrap the returned binder in a {@link NullableColumnBinder}.
+ *
+ *
To handle null values, wrap the returned binder in a {@link NullableColumnBinder}.
*/
public class ColumnBinderArrowTypeVisitor implements ArrowType.ArrowTypeVisitor {
private final FieldVector vector;
@@ -111,17 +110,21 @@ public ColumnBinder visit(ArrowType.Int type) {
}
switch (type.getBitWidth()) {
case 8:
- return jdbcType == null ? new TinyIntBinder((TinyIntVector) vector) :
- new TinyIntBinder((TinyIntVector) vector, jdbcType);
+ return jdbcType == null
+ ? new TinyIntBinder((TinyIntVector) vector)
+ : new TinyIntBinder((TinyIntVector) vector, jdbcType);
case 16:
- return jdbcType == null ? new SmallIntBinder((SmallIntVector) vector) :
- new SmallIntBinder((SmallIntVector) vector, jdbcType);
+ return jdbcType == null
+ ? new SmallIntBinder((SmallIntVector) vector)
+ : new SmallIntBinder((SmallIntVector) vector, jdbcType);
case 32:
- return jdbcType == null ? new IntBinder((IntVector) vector) :
- new IntBinder((IntVector) vector, jdbcType);
+ return jdbcType == null
+ ? new IntBinder((IntVector) vector)
+ : new IntBinder((IntVector) vector, jdbcType);
case 64:
- return jdbcType == null ? new BigIntBinder((BigIntVector) vector) :
- new BigIntBinder((BigIntVector) vector, jdbcType);
+ return jdbcType == null
+ ? new BigIntBinder((BigIntVector) vector)
+ : new BigIntBinder((BigIntVector) vector, jdbcType);
default:
throw new UnsupportedOperationException("No column binder implemented for type " + type);
}
@@ -131,11 +134,13 @@ public ColumnBinder visit(ArrowType.Int type) {
public ColumnBinder visit(ArrowType.FloatingPoint type) {
switch (type.getPrecision()) {
case SINGLE:
- return jdbcType == null ? new Float4Binder((Float4Vector) vector) :
- new Float4Binder((Float4Vector) vector, jdbcType);
+ return jdbcType == null
+ ? new Float4Binder((Float4Vector) vector)
+ : new Float4Binder((Float4Vector) vector, jdbcType);
case DOUBLE:
- return jdbcType == null ? new Float8Binder((Float8Vector) vector) :
- new Float8Binder((Float8Vector) vector, jdbcType);
+ return jdbcType == null
+ ? new Float8Binder((Float8Vector) vector)
+ : new Float8Binder((Float8Vector) vector, jdbcType);
default:
throw new UnsupportedOperationException("No column binder implemented for type " + type);
}
@@ -144,51 +149,62 @@ public ColumnBinder visit(ArrowType.FloatingPoint type) {
@Override
public ColumnBinder visit(ArrowType.Utf8 type) {
VarCharVector varChar = (VarCharVector) vector;
- return jdbcType == null ? new VarCharBinder<>(varChar, Types.VARCHAR) :
- new VarCharBinder<>(varChar, jdbcType);
+ return jdbcType == null
+ ? new VarCharBinder<>(varChar, Types.VARCHAR)
+ : new VarCharBinder<>(varChar, jdbcType);
}
@Override
public ColumnBinder visit(ArrowType.LargeUtf8 type) {
LargeVarCharVector varChar = (LargeVarCharVector) vector;
- return jdbcType == null ? new VarCharBinder<>(varChar, Types.LONGVARCHAR) :
- new VarCharBinder<>(varChar, jdbcType);
+ return jdbcType == null
+ ? new VarCharBinder<>(varChar, Types.LONGVARCHAR)
+ : new VarCharBinder<>(varChar, jdbcType);
}
@Override
public ColumnBinder visit(ArrowType.Binary type) {
VarBinaryVector varBinary = (VarBinaryVector) vector;
- return jdbcType == null ? new VarBinaryBinder<>(varBinary, Types.VARBINARY) :
- new VarBinaryBinder<>(varBinary, jdbcType);
+ return jdbcType == null
+ ? new VarBinaryBinder<>(varBinary, Types.VARBINARY)
+ : new VarBinaryBinder<>(varBinary, jdbcType);
}
@Override
public ColumnBinder visit(ArrowType.LargeBinary type) {
LargeVarBinaryVector varBinary = (LargeVarBinaryVector) vector;
- return jdbcType == null ? new VarBinaryBinder<>(varBinary, Types.LONGVARBINARY) :
- new VarBinaryBinder<>(varBinary, jdbcType);
+ return jdbcType == null
+ ? new VarBinaryBinder<>(varBinary, Types.LONGVARBINARY)
+ : new VarBinaryBinder<>(varBinary, jdbcType);
}
@Override
public ColumnBinder visit(ArrowType.FixedSizeBinary type) {
FixedSizeBinaryVector binary = (FixedSizeBinaryVector) vector;
- return jdbcType == null ? new FixedSizeBinaryBinder(binary, Types.BINARY) :
- new FixedSizeBinaryBinder(binary, jdbcType);
+ return jdbcType == null
+ ? new FixedSizeBinaryBinder(binary, Types.BINARY)
+ : new FixedSizeBinaryBinder(binary, jdbcType);
}
@Override
public ColumnBinder visit(ArrowType.Bool type) {
- return jdbcType == null ? new BitBinder((BitVector) vector) : new BitBinder((BitVector) vector, jdbcType);
+ return jdbcType == null
+ ? new BitBinder((BitVector) vector)
+ : new BitBinder((BitVector) vector, jdbcType);
}
@Override
public ColumnBinder visit(ArrowType.Decimal type) {
if (type.getBitWidth() == 128) {
DecimalVector decimalVector = (DecimalVector) vector;
- return jdbcType == null ? new Decimal128Binder(decimalVector) : new Decimal128Binder(decimalVector, jdbcType);
+ return jdbcType == null
+ ? new Decimal128Binder(decimalVector)
+ : new Decimal128Binder(decimalVector, jdbcType);
} else if (type.getBitWidth() == 256) {
Decimal256Vector decimalVector = (Decimal256Vector) vector;
- return jdbcType == null ? new Decimal256Binder(decimalVector) : new Decimal256Binder(decimalVector, jdbcType);
+ return jdbcType == null
+ ? new Decimal256Binder(decimalVector)
+ : new Decimal256Binder(decimalVector, jdbcType);
}
throw new UnsupportedOperationException("No column binder implemented for type " + type);
}
@@ -197,11 +213,13 @@ public ColumnBinder visit(ArrowType.Decimal type) {
public ColumnBinder visit(ArrowType.Date type) {
switch (type.getUnit()) {
case DAY:
- return jdbcType == null ? new DateDayBinder((DateDayVector) vector) :
- new DateDayBinder((DateDayVector) vector, /*calendar*/null, jdbcType);
+ return jdbcType == null
+ ? new DateDayBinder((DateDayVector) vector)
+ : new DateDayBinder((DateDayVector) vector, /*calendar*/ null, jdbcType);
case MILLISECOND:
- return jdbcType == null ? new DateMilliBinder((DateMilliVector) vector) :
- new DateMilliBinder((DateMilliVector) vector, /*calendar*/null, jdbcType);
+ return jdbcType == null
+ ? new DateMilliBinder((DateMilliVector) vector)
+ : new DateMilliBinder((DateMilliVector) vector, /*calendar*/ null, jdbcType);
default:
throw new UnsupportedOperationException("No column binder implemented for type " + type);
}
@@ -211,17 +229,21 @@ public ColumnBinder visit(ArrowType.Date type) {
public ColumnBinder visit(ArrowType.Time type) {
switch (type.getUnit()) {
case SECOND:
- return jdbcType == null ? new Time32Binder((TimeSecVector) vector) :
- new Time32Binder((TimeSecVector) vector, jdbcType);
+ return jdbcType == null
+ ? new Time32Binder((TimeSecVector) vector)
+ : new Time32Binder((TimeSecVector) vector, jdbcType);
case MILLISECOND:
- return jdbcType == null ? new Time32Binder((TimeMilliVector) vector) :
- new Time32Binder((TimeMilliVector) vector, jdbcType);
+ return jdbcType == null
+ ? new Time32Binder((TimeMilliVector) vector)
+ : new Time32Binder((TimeMilliVector) vector, jdbcType);
case MICROSECOND:
- return jdbcType == null ? new Time64Binder((TimeMicroVector) vector) :
- new Time64Binder((TimeMicroVector) vector, jdbcType);
+ return jdbcType == null
+ ? new Time64Binder((TimeMicroVector) vector)
+ : new Time64Binder((TimeMicroVector) vector, jdbcType);
case NANOSECOND:
- return jdbcType == null ? new Time64Binder((TimeNanoVector) vector) :
- new Time64Binder((TimeNanoVector) vector, jdbcType);
+ return jdbcType == null
+ ? new Time64Binder((TimeNanoVector) vector)
+ : new Time64Binder((TimeNanoVector) vector, jdbcType);
default:
throw new UnsupportedOperationException("No column binder implemented for type " + type);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateDayBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateDayBinder.java
index bc16790c8f3..92686d54203 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateDayBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateDayBinder.java
@@ -22,12 +22,9 @@
import java.sql.SQLException;
import java.sql.Types;
import java.util.Calendar;
-
import org.apache.arrow.vector.DateDayVector;
-/**
- * A column binder for 32-bit dates.
- */
+/** A column binder for 32-bit dates. */
public class DateDayBinder extends BaseColumnBinder {
private static final long MILLIS_PER_DAY = 86_400_000;
private final Calendar calendar;
@@ -46,7 +43,8 @@ public DateDayBinder(DateDayVector vector, Calendar calendar, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
// TODO: multiply with overflow
final long index = (long) rowIndex * DateDayVector.TYPE_WIDTH;
final Date value = new Date(vector.getDataBuffer().getInt(index) * MILLIS_PER_DAY);
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateMilliBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateMilliBinder.java
index 5cb91b46ac1..df2dcc8639d 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateMilliBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/DateMilliBinder.java
@@ -22,12 +22,9 @@
import java.sql.SQLException;
import java.sql.Types;
import java.util.Calendar;
-
import org.apache.arrow.vector.DateMilliVector;
-/**
- * A column binder for 64-bit dates.
- */
+/** A column binder for 64-bit dates. */
public class DateMilliBinder extends BaseColumnBinder {
private final Calendar calendar;
@@ -39,14 +36,14 @@ public DateMilliBinder(DateMilliVector vector, Calendar calendar) {
this(vector, calendar, Types.DATE);
}
-
public DateMilliBinder(DateMilliVector vector, Calendar calendar, int jdbcType) {
super(vector, jdbcType);
this.calendar = calendar;
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
final long index = (long) rowIndex * DateMilliVector.TYPE_WIDTH;
final Date value = new Date(vector.getDataBuffer().getLong(index));
if (calendar == null) {
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal128Binder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal128Binder.java
index 9e9d0e4fdb2..7f7e8774510 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal128Binder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal128Binder.java
@@ -21,13 +21,10 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.DecimalVector;
import org.apache.arrow.vector.util.DecimalUtility;
-/**
- * A binder for 128-bit decimals.
- */
+/** A binder for 128-bit decimals. */
public class Decimal128Binder extends BaseColumnBinder {
public Decimal128Binder(DecimalVector vector) {
this(vector, Types.DECIMAL);
@@ -38,9 +35,11 @@ public Decimal128Binder(DecimalVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
- final BigDecimal value = DecimalUtility.getBigDecimalFromArrowBuf(
- vector.getDataBuffer(), rowIndex, vector.getScale(), DecimalVector.TYPE_WIDTH);
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
+ final BigDecimal value =
+ DecimalUtility.getBigDecimalFromArrowBuf(
+ vector.getDataBuffer(), rowIndex, vector.getScale(), DecimalVector.TYPE_WIDTH);
statement.setBigDecimal(parameterIndex, value);
}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal256Binder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal256Binder.java
index bd29e083b45..38de58f76e1 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal256Binder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Decimal256Binder.java
@@ -21,13 +21,10 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.Decimal256Vector;
import org.apache.arrow.vector.util.DecimalUtility;
-/**
- * A binder for 256-bit decimals.
- */
+/** A binder for 256-bit decimals. */
public class Decimal256Binder extends BaseColumnBinder {
public Decimal256Binder(Decimal256Vector vector) {
this(vector, Types.DECIMAL);
@@ -38,9 +35,11 @@ public Decimal256Binder(Decimal256Vector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
- final BigDecimal value = DecimalUtility.getBigDecimalFromArrowBuf(
- vector.getDataBuffer(), rowIndex, vector.getScale(), Decimal256Vector.TYPE_WIDTH);
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
+ final BigDecimal value =
+ DecimalUtility.getBigDecimalFromArrowBuf(
+ vector.getDataBuffer(), rowIndex, vector.getScale(), Decimal256Vector.TYPE_WIDTH);
statement.setBigDecimal(parameterIndex, value);
}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/FixedSizeBinaryBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/FixedSizeBinaryBinder.java
index 7edc5e45329..6f39ffe4db3 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/FixedSizeBinaryBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/FixedSizeBinaryBinder.java
@@ -19,17 +19,14 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
-
import org.apache.arrow.vector.FixedSizeBinaryVector;
-/**
- * A binder for fixed-width binary types.
- */
+/** A binder for fixed-width binary types. */
public class FixedSizeBinaryBinder extends BaseColumnBinder {
/**
* Create a binder for the given vector using the given JDBC type for null values.
*
- * @param vector The vector to draw values from.
+ * @param vector The vector to draw values from.
* @param jdbcType The JDBC type code.
*/
public FixedSizeBinaryBinder(FixedSizeBinaryVector vector, int jdbcType) {
@@ -37,9 +34,12 @@ public FixedSizeBinaryBinder(FixedSizeBinaryVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
byte[] binaryData = new byte[vector.getByteWidth()];
- vector.getDataBuffer().getBytes((long) rowIndex * binaryData.length, binaryData, 0, binaryData.length);
+ vector
+ .getDataBuffer()
+ .getBytes((long) rowIndex * binaryData.length, binaryData, 0, binaryData.length);
statement.setBytes(parameterIndex, binaryData);
}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float4Binder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float4Binder.java
index a471c1ebadd..af3a3b21604 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float4Binder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float4Binder.java
@@ -20,12 +20,9 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.Float4Vector;
-/**
- * A binder for 32-bit floats.
- */
+/** A binder for 32-bit floats. */
public class Float4Binder extends BaseColumnBinder {
public Float4Binder(Float4Vector vector) {
this(vector, Types.REAL);
@@ -36,7 +33,8 @@ public Float4Binder(Float4Vector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
final float value = vector.getDataBuffer().getFloat((long) rowIndex * Float4Vector.TYPE_WIDTH);
statement.setFloat(parameterIndex, value);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float8Binder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float8Binder.java
index 4710c3b5986..c85dc926ac0 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float8Binder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Float8Binder.java
@@ -20,12 +20,9 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.Float8Vector;
-/**
- * A binder for 64-bit floats.
- */
+/** A binder for 64-bit floats. */
public class Float8Binder extends BaseColumnBinder {
public Float8Binder(Float8Vector vector) {
this(vector, Types.DOUBLE);
@@ -36,8 +33,10 @@ public Float8Binder(Float8Vector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
- final double value = vector.getDataBuffer().getDouble((long) rowIndex * Float8Vector.TYPE_WIDTH);
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
+ final double value =
+ vector.getDataBuffer().getDouble((long) rowIndex * Float8Vector.TYPE_WIDTH);
statement.setDouble(parameterIndex, value);
}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/IntBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/IntBinder.java
index 7d47f585a39..2d3bdbab4a8 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/IntBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/IntBinder.java
@@ -20,7 +20,6 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.IntVector;
/** A column binder for 32-bit integers. */
@@ -34,7 +33,8 @@ public IntBinder(IntVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
final int value = vector.getDataBuffer().getInt((long) rowIndex * IntVector.TYPE_WIDTH);
statement.setInt(parameterIndex, value);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ListBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ListBinder.java
index b8aa61234f4..7d59cb8ea01 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ListBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/ListBinder.java
@@ -20,15 +20,12 @@
import java.lang.reflect.Array;
import java.util.ArrayList;
import java.util.Arrays;
-
import org.apache.arrow.vector.FieldVector;
import org.apache.arrow.vector.complex.ListVector;
import org.apache.arrow.vector.complex.impl.UnionListReader;
import org.apache.arrow.vector.util.Text;
-/**
- * A column binder for list of primitive values.
- */
+/** A column binder for list of primitive values. */
public class ListBinder extends BaseColumnBinder {
private final UnionListReader listReader;
@@ -52,7 +49,9 @@ public ListBinder(ListVector vector, int jdbcType) {
try {
arrayElementClass = dataVectorClass.getMethod("getObject", Integer.TYPE).getReturnType();
} catch (NoSuchMethodException e) {
- final String message = String.format("Issue to determine type for getObject method of data vector class %s ",
+ final String message =
+ String.format(
+ "Issue to determine type for getObject method of data vector class %s ",
dataVectorClass.getName());
throw new RuntimeException(message);
}
@@ -60,7 +59,8 @@ public ListBinder(ListVector vector, int jdbcType) {
}
@Override
- public void bind(java.sql.PreparedStatement statement, int parameterIndex, int rowIndex)throws java.sql.SQLException {
+ public void bind(java.sql.PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws java.sql.SQLException {
listReader.setPosition(rowIndex);
ArrayList sourceArray = (ArrayList) listReader.readObject();
Object array;
@@ -69,7 +69,9 @@ public void bind(java.sql.PreparedStatement statement, int parameterIndex, int r
Arrays.setAll((Object[]) array, sourceArray::get);
} else {
array = new String[sourceArray.size()];
- Arrays.setAll((Object[]) array, idx -> sourceArray.get(idx) != null ? sourceArray.get(idx).toString() : null);
+ Arrays.setAll(
+ (Object[]) array,
+ idx -> sourceArray.get(idx) != null ? sourceArray.get(idx).toString() : null);
}
statement.setObject(parameterIndex, array);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/MapBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/MapBinder.java
index 07391eb7cbf..6e347a18123 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/MapBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/MapBinder.java
@@ -23,16 +23,13 @@
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Objects;
-
import org.apache.arrow.vector.complex.MapVector;
import org.apache.arrow.vector.complex.impl.UnionMapReader;
import org.apache.arrow.vector.types.pojo.ArrowType;
import org.apache.arrow.vector.types.pojo.Field;
import org.apache.arrow.vector.util.JsonStringHashMap;
-/**
- * A column binder for map of primitive values.
- */
+/** A column binder for map of primitive values. */
public class MapBinder extends BaseColumnBinder {
private UnionMapReader reader;
@@ -58,8 +55,8 @@ public MapBinder(MapVector vector, int jdbcType) {
}
List keyValueFields = Objects.requireNonNull(structField.get(0)).getChildren();
if (keyValueFields.size() != 2) {
- throw new IllegalArgumentException("Expected two children fields " +
- "inside nested Struct field in Map");
+ throw new IllegalArgumentException(
+ "Expected two children fields " + "inside nested Struct field in Map");
}
ArrowType keyType = Objects.requireNonNull(keyValueFields.get(0)).getType();
ArrowType valueType = Objects.requireNonNull(keyValueFields.get(1)).getType();
@@ -68,15 +65,16 @@ public MapBinder(MapVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement,
- int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
reader.setPosition(rowIndex);
LinkedHashMap tags = new JsonStringHashMap<>();
while (reader.next()) {
Object key = reader.key().readObject();
Object value = reader.value().readObject();
- tags.put(isTextKey && key != null ? key.toString() : key,
- isTextValue && value != null ? value.toString() : value);
+ tags.put(
+ isTextKey && key != null ? key.toString() : key,
+ isTextValue && value != null ? value.toString() : value);
}
switch (jdbcType) {
case Types.VARCHAR:
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/NullableColumnBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/NullableColumnBinder.java
index 123b587ca50..202a723c51a 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/NullableColumnBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/NullableColumnBinder.java
@@ -19,12 +19,9 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
-
import org.apache.arrow.vector.FieldVector;
-/**
- * A ColumnBinder that checks for nullability before deferring to a type-specific binder.
- */
+/** A ColumnBinder that checks for nullability before deferring to a type-specific binder. */
public class NullableColumnBinder implements ColumnBinder {
private final ColumnBinder wrapped;
@@ -33,7 +30,8 @@ public NullableColumnBinder(ColumnBinder wrapped) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
if (wrapped.getVector().isNull(rowIndex)) {
statement.setNull(parameterIndex, wrapped.getJdbcType());
} else {
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/SmallIntBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/SmallIntBinder.java
index f9d744b9f54..81af48d83f7 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/SmallIntBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/SmallIntBinder.java
@@ -20,7 +20,6 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.SmallIntVector;
/** A column binder for 8-bit integers. */
@@ -34,8 +33,10 @@ public SmallIntBinder(SmallIntVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
- final short value = vector.getDataBuffer().getShort((short) rowIndex * SmallIntVector.TYPE_WIDTH);
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
+ final short value =
+ vector.getDataBuffer().getShort((short) rowIndex * SmallIntVector.TYPE_WIDTH);
statement.setShort(parameterIndex, value);
}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time32Binder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time32Binder.java
index 5dc7e3f513f..ec09ae53cd8 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time32Binder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time32Binder.java
@@ -21,14 +21,11 @@
import java.sql.SQLException;
import java.sql.Time;
import java.sql.Types;
-
import org.apache.arrow.vector.BaseFixedWidthVector;
import org.apache.arrow.vector.TimeMilliVector;
import org.apache.arrow.vector.TimeSecVector;
-/**
- * A binder for 32-bit time types.
- */
+/** A binder for 32-bit time types. */
public class Time32Binder extends BaseColumnBinder {
private static final long TYPE_WIDTH = 4;
@@ -43,11 +40,11 @@ public Time32Binder(TimeMilliVector vector) {
}
public Time32Binder(TimeSecVector vector, int jdbcType) {
- this(vector, /*factor*/1_000, jdbcType);
+ this(vector, /*factor*/ 1_000, jdbcType);
}
public Time32Binder(TimeMilliVector vector, int jdbcType) {
- this(vector, /*factor*/1, jdbcType);
+ this(vector, /*factor*/ 1, jdbcType);
}
Time32Binder(BaseFixedWidthVector vector, long factor, int jdbcType) {
@@ -56,7 +53,8 @@ public Time32Binder(TimeMilliVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
// TODO: multiply with overflow
// TODO: take in a Calendar as well?
final Time value = new Time(vector.getDataBuffer().getInt(rowIndex * TYPE_WIDTH) * factor);
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time64Binder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time64Binder.java
index 8d62ae0eb36..0c858bc46be 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time64Binder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/Time64Binder.java
@@ -21,14 +21,11 @@
import java.sql.SQLException;
import java.sql.Time;
import java.sql.Types;
-
import org.apache.arrow.vector.BaseFixedWidthVector;
import org.apache.arrow.vector.TimeMicroVector;
import org.apache.arrow.vector.TimeNanoVector;
-/**
- * A binder for 64-bit time types.
- */
+/** A binder for 64-bit time types. */
public class Time64Binder extends BaseColumnBinder {
private static final long TYPE_WIDTH = 8;
@@ -43,11 +40,11 @@ public Time64Binder(TimeNanoVector vector) {
}
public Time64Binder(TimeMicroVector vector, int jdbcType) {
- this(vector, /*factor*/1_000, jdbcType);
+ this(vector, /*factor*/ 1_000, jdbcType);
}
public Time64Binder(TimeNanoVector vector, int jdbcType) {
- this(vector, /*factor*/1_000_000, jdbcType);
+ this(vector, /*factor*/ 1_000_000, jdbcType);
}
Time64Binder(BaseFixedWidthVector vector, long factor, int jdbcType) {
@@ -56,7 +53,8 @@ public Time64Binder(TimeNanoVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
// TODO: option to throw on truncation (vendor Guava IntMath#multiply)
final Time value = new Time(vector.getDataBuffer().getLong(rowIndex * TYPE_WIDTH) / factor);
statement.setTime(parameterIndex, value);
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TimeStampBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TimeStampBinder.java
index 6677e590990..7e0de9ee59b 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TimeStampBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TimeStampBinder.java
@@ -22,7 +22,6 @@
import java.sql.Timestamp;
import java.sql.Types;
import java.util.Calendar;
-
import org.apache.arrow.vector.TimeStampVector;
import org.apache.arrow.vector.types.pojo.ArrowType;
@@ -32,15 +31,17 @@ public class TimeStampBinder extends BaseColumnBinder {
private final long unitsPerSecond;
private final long nanosPerUnit;
- /**
- * Create a binder for a timestamp vector using the default JDBC type code.
- */
+ /** Create a binder for a timestamp vector using the default JDBC type code. */
public TimeStampBinder(TimeStampVector vector, Calendar calendar) {
- this(vector, calendar, isZoned(vector.getField().getType()) ? Types.TIMESTAMP_WITH_TIMEZONE : Types.TIMESTAMP);
+ this(
+ vector,
+ calendar,
+ isZoned(vector.getField().getType()) ? Types.TIMESTAMP_WITH_TIMEZONE : Types.TIMESTAMP);
}
/**
* Create a binder for a timestamp vector.
+ *
* @param vector The vector to pull values from.
* @param calendar Optionally, the calendar to pass to JDBC.
* @param jdbcType The JDBC type code to use for null values.
@@ -73,19 +74,23 @@ public TimeStampBinder(TimeStampVector vector, Calendar calendar, int jdbcType)
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
// TODO: option to throw on truncation (vendor Guava IntMath#multiply) or overflow
- final long rawValue = vector.getDataBuffer().getLong((long) rowIndex * TimeStampVector.TYPE_WIDTH);
+ final long rawValue =
+ vector.getDataBuffer().getLong((long) rowIndex * TimeStampVector.TYPE_WIDTH);
final long seconds = rawValue / unitsPerSecond;
final int nanos = (int) ((rawValue - (seconds * unitsPerSecond)) * nanosPerUnit);
final Timestamp value = new Timestamp(seconds * 1_000);
value.setNanos(nanos);
if (calendar != null) {
- // Timestamp == Date == UTC timestamp (confusingly). Arrow's timestamp with timezone is a UTC value with a
+ // Timestamp == Date == UTC timestamp (confusingly). Arrow's timestamp with timezone is a UTC
+ // value with a
// zone offset, so we don't need to do any conversion.
statement.setTimestamp(parameterIndex, value, calendar);
} else {
- // Arrow timestamp without timezone isn't strictly convertible to any timezone. So this is technically wrong,
+ // Arrow timestamp without timezone isn't strictly convertible to any timezone. So this is
+ // technically wrong,
// but there is no 'correct' interpretation here. The application should provide a calendar.
statement.setTimestamp(parameterIndex, value);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TinyIntBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TinyIntBinder.java
index f51d139be86..d430b74ead3 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TinyIntBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/TinyIntBinder.java
@@ -20,7 +20,6 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Types;
-
import org.apache.arrow.vector.TinyIntVector;
/** A column binder for 8-bit integers. */
@@ -34,7 +33,8 @@ public TinyIntBinder(TinyIntVector vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
final byte value = vector.getDataBuffer().getByte((long) rowIndex * TinyIntVector.TYPE_WIDTH);
statement.setByte(parameterIndex, value);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarBinaryBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarBinaryBinder.java
index a94cff6a004..54082d8aa52 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarBinaryBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarBinaryBinder.java
@@ -19,7 +19,6 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
-
import org.apache.arrow.memory.util.ArrowBufPointer;
import org.apache.arrow.vector.ElementAddressableVector;
import org.apache.arrow.vector.FieldVector;
@@ -29,13 +28,14 @@
*
* @param The binary vector.
*/
-public class VarBinaryBinder extends BaseColumnBinder {
+public class VarBinaryBinder
+ extends BaseColumnBinder {
private final ArrowBufPointer element;
/**
* Create a binder for the given vector using the given JDBC type for null values.
*
- * @param vector The vector to draw values from.
+ * @param vector The vector to draw values from.
* @param jdbcType The JDBC type code.
*/
public VarBinaryBinder(T vector, int jdbcType) {
@@ -44,15 +44,18 @@ public VarBinaryBinder(T vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
vector.getDataPointer(rowIndex, element);
if (element.getBuf() == null) {
statement.setNull(parameterIndex, jdbcType);
return;
}
if (element.getLength() > (long) Integer.MAX_VALUE) {
- final String message = String.format("Length of value at index %d (%d) exceeds Integer.MAX_VALUE",
- rowIndex, element.getLength());
+ final String message =
+ String.format(
+ "Length of value at index %d (%d) exceeds Integer.MAX_VALUE",
+ rowIndex, element.getLength());
throw new RuntimeException(message);
}
byte[] binaryData = new byte[(int) element.getLength()];
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarCharBinder.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarCharBinder.java
index 73bd5598149..5200506d333 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarCharBinder.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/VarCharBinder.java
@@ -20,7 +20,6 @@
import java.nio.charset.StandardCharsets;
import java.sql.PreparedStatement;
import java.sql.SQLException;
-
import org.apache.arrow.memory.util.ArrowBufPointer;
import org.apache.arrow.vector.FieldVector;
import org.apache.arrow.vector.VariableWidthVector;
@@ -30,13 +29,14 @@
*
* @param The text vector.
*/
-public class VarCharBinder extends BaseColumnBinder {
+public class VarCharBinder
+ extends BaseColumnBinder {
private final ArrowBufPointer element;
/**
* Create a binder for the given vector using the given JDBC type for null values.
*
- * @param vector The vector to draw values from.
+ * @param vector The vector to draw values from.
* @param jdbcType The JDBC type code.
*/
public VarCharBinder(T vector, int jdbcType) {
@@ -45,15 +45,18 @@ public VarCharBinder(T vector, int jdbcType) {
}
@Override
- public void bind(PreparedStatement statement, int parameterIndex, int rowIndex) throws SQLException {
+ public void bind(PreparedStatement statement, int parameterIndex, int rowIndex)
+ throws SQLException {
vector.getDataPointer(rowIndex, element);
if (element.getBuf() == null) {
statement.setNull(parameterIndex, jdbcType);
return;
}
if (element.getLength() > (long) Integer.MAX_VALUE) {
- final String message = String.format("Length of value at index %d (%d) exceeds Integer.MAX_VALUE",
- rowIndex, element.getLength());
+ final String message =
+ String.format(
+ "Length of value at index %d (%d) exceeds Integer.MAX_VALUE",
+ rowIndex, element.getLength());
throw new RuntimeException(message);
}
byte[] utf8Bytes = new byte[(int) element.getLength()];
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/package-info.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/package-info.java
index 4f8936e0c27..945c3c9f84f 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/package-info.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/binder/package-info.java
@@ -15,8 +15,5 @@
* limitations under the License.
*/
-/**
- * Utilities to bind Arrow data as JDBC prepared statement parameters.
- */
-
+/** Utilities to bind Arrow data as JDBC prepared statement parameters. */
package org.apache.arrow.adapter.jdbc.binder;
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ArrayConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ArrayConsumer.java
index 2f18b8a416d..620f9bb0b30 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ArrayConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ArrayConsumer.java
@@ -21,22 +21,19 @@
import java.sql.Array;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.FieldVector;
import org.apache.arrow.vector.ValueVector;
import org.apache.arrow.vector.complex.ListVector;
/**
- * Consumer which consume array type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.complex.ListVector}.
+ * Consumer which consume array type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.complex.ListVector}.
*/
public abstract class ArrayConsumer extends BaseConsumer {
- /**
- * Creates a consumer for {@link ListVector}.
- */
+ /** Creates a consumer for {@link ListVector}. */
public static ArrayConsumer createConsumer(
- ListVector vector, JdbcConsumer delegate, int index, boolean nullable) {
+ ListVector vector, JdbcConsumer delegate, int index, boolean nullable) {
if (nullable) {
return new ArrayConsumer.NullableArrayConsumer(vector, delegate, index);
} else {
@@ -50,9 +47,7 @@ public static ArrayConsumer createConsumer(
protected int innerVectorIndex = 0;
- /**
- * Instantiate a ArrayConsumer.
- */
+ /** Instantiate a ArrayConsumer. */
public ArrayConsumer(ListVector vector, JdbcConsumer delegate, int index) {
super(vector, index);
this.delegate = delegate;
@@ -81,14 +76,10 @@ void ensureInnerVectorCapacity(int targetCapacity) {
}
}
- /**
- * Nullable consumer for {@link ListVector}.
- */
+ /** Nullable consumer for {@link ListVector}. */
static class NullableArrayConsumer extends ArrayConsumer {
- /**
- * Instantiate a nullable array consumer.
- */
+ /** Instantiate a nullable array consumer. */
public NullableArrayConsumer(ListVector vector, JdbcConsumer delegate, int index) {
super(vector, delegate, index);
}
@@ -113,14 +104,10 @@ public void consume(ResultSet resultSet) throws SQLException, IOException {
}
}
- /**
- * Non-nullable consumer for {@link ListVector}.
- */
+ /** Non-nullable consumer for {@link ListVector}. */
static class NonNullableArrayConsumer extends ArrayConsumer {
- /**
- * Instantiate a nullable array consumer.
- */
+ /** Instantiate a nullable array consumer. */
public NonNullableArrayConsumer(ListVector vector, JdbcConsumer delegate, int index) {
super(vector, delegate, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BaseConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BaseConsumer.java
index 2db128d3e2b..8c5c0209455 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BaseConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BaseConsumer.java
@@ -21,6 +21,7 @@
/**
* Base class for all consumers.
+ *
* @param vector type.
*/
public abstract class BaseConsumer implements JdbcConsumer {
@@ -33,6 +34,7 @@ public abstract class BaseConsumer implements JdbcConsume
/**
* Constructs a new consumer.
+ *
* @param vector the underlying vector for the consumer.
* @param index the column id for the consumer.
*/
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BigIntConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BigIntConsumer.java
index 19c8efa9171..532103c8900 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BigIntConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BigIntConsumer.java
@@ -19,19 +19,17 @@
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.BigIntVector;
/**
- * Consumer which consume bigint type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.BigIntVector}.
+ * Consumer which consume bigint type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.BigIntVector}.
*/
public class BigIntConsumer {
- /**
- * Creates a consumer for {@link BigIntVector}.
- */
- public static JdbcConsumer createConsumer(BigIntVector vector, int index, boolean nullable) {
+ /** Creates a consumer for {@link BigIntVector}. */
+ public static JdbcConsumer createConsumer(
+ BigIntVector vector, int index, boolean nullable) {
if (nullable) {
return new NullableBigIntConsumer(vector, index);
} else {
@@ -39,14 +37,10 @@ public static JdbcConsumer createConsumer(BigIntVector vector, int
}
}
- /**
- * Nullable consumer for big int.
- */
+ /** Nullable consumer for big int. */
static class NullableBigIntConsumer extends BaseConsumer {
- /**
- * Instantiate a BigIntConsumer.
- */
+ /** Instantiate a BigIntConsumer. */
public NullableBigIntConsumer(BigIntVector vector, int index) {
super(vector, index);
}
@@ -63,14 +57,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for big int.
- */
+ /** Non-nullable consumer for big int. */
static class NonNullableBigIntConsumer extends BaseConsumer {
- /**
- * Instantiate a BigIntConsumer.
- */
+ /** Instantiate a BigIntConsumer. */
public NonNullableBigIntConsumer(BigIntVector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BinaryConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BinaryConsumer.java
index 8c5f61169d4..b0f6fce30b3 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BinaryConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BinaryConsumer.java
@@ -21,20 +21,17 @@
import java.io.InputStream;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.memory.ArrowBuf;
import org.apache.arrow.vector.BitVectorHelper;
import org.apache.arrow.vector.VarBinaryVector;
/**
- * Consumer which consume binary type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.VarBinaryVector}.
+ * Consumer which consume binary type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.VarBinaryVector}.
*/
public abstract class BinaryConsumer extends BaseConsumer {
- /**
- * Creates a consumer for {@link VarBinaryVector}.
- */
+ /** Creates a consumer for {@link VarBinaryVector}. */
public static BinaryConsumer createConsumer(VarBinaryVector vector, int index, boolean nullable) {
if (nullable) {
return new NullableBinaryConsumer(vector, index);
@@ -45,9 +42,7 @@ public static BinaryConsumer createConsumer(VarBinaryVector vector, int index, b
private final byte[] reuseBytes = new byte[1024];
- /**
- * Instantiate a BinaryConsumer.
- */
+ /** Instantiate a BinaryConsumer. */
public BinaryConsumer(VarBinaryVector vector, int index) {
super(vector, index);
if (vector != null) {
@@ -55,9 +50,7 @@ public BinaryConsumer(VarBinaryVector vector, int index) {
}
}
- /**
- * consume a InputStream.
- */
+ /** consume a InputStream. */
public void consume(InputStream is) throws IOException {
if (is != null) {
while (currentIndex >= vector.getValueCapacity()) {
@@ -74,7 +67,8 @@ public void consume(InputStream is) throws IOException {
vector.getDataBuffer().setBytes(startOffset + dataLength, reuseBytes, 0, read);
dataLength += read;
}
- offsetBuffer.setInt((currentIndex + 1) * VarBinaryVector.OFFSET_WIDTH, startOffset + dataLength);
+ offsetBuffer.setInt(
+ (currentIndex + 1) * VarBinaryVector.OFFSET_WIDTH, startOffset + dataLength);
BitVectorHelper.setBit(vector.getValidityBuffer(), currentIndex);
vector.setLastSet(currentIndex);
}
@@ -91,14 +85,10 @@ public void resetValueVector(VarBinaryVector vector) {
this.currentIndex = 0;
}
- /**
- * Consumer for nullable binary data.
- */
+ /** Consumer for nullable binary data. */
static class NullableBinaryConsumer extends BinaryConsumer {
-
- /**
- * Instantiate a BinaryConsumer.
- */
+
+ /** Instantiate a BinaryConsumer. */
public NullableBinaryConsumer(VarBinaryVector vector, int index) {
super(vector, index);
}
@@ -113,14 +103,10 @@ public void consume(ResultSet resultSet) throws SQLException, IOException {
}
}
- /**
- * Consumer for non-nullable binary data.
- */
+ /** Consumer for non-nullable binary data. */
static class NonNullableBinaryConsumer extends BinaryConsumer {
- /**
- * Instantiate a BinaryConsumer.
- */
+ /** Instantiate a BinaryConsumer. */
public NonNullableBinaryConsumer(VarBinaryVector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BitConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BitConsumer.java
index d2d94d0a40e..18ce8fd9746 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BitConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BitConsumer.java
@@ -19,19 +19,17 @@
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.BitVector;
/**
- * Consumer which consume bit type values from {@link ResultSet}.
- * Write the data to {@link BitVector}.
+ * Consumer which consume bit type values from {@link ResultSet}. Write the data to {@link
+ * BitVector}.
*/
public class BitConsumer {
- /**
- * Creates a consumer for {@link BitVector}.
- */
- public static JdbcConsumer createConsumer(BitVector vector, int index, boolean nullable) {
+ /** Creates a consumer for {@link BitVector}. */
+ public static JdbcConsumer createConsumer(
+ BitVector vector, int index, boolean nullable) {
if (nullable) {
return new NullableBitConsumer(vector, index);
} else {
@@ -39,14 +37,10 @@ public static JdbcConsumer createConsumer(BitVector vector, int index
}
}
- /**
- * Nullable consumer for {@link BitVector}.
- */
+ /** Nullable consumer for {@link BitVector}. */
static class NullableBitConsumer extends BaseConsumer {
- /**
- * Instantiate a BitConsumer.
- */
+ /** Instantiate a BitConsumer. */
public NullableBitConsumer(BitVector vector, int index) {
super(vector, index);
}
@@ -63,14 +57,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for {@link BitVector}.
- */
+ /** Non-nullable consumer for {@link BitVector}. */
static class NonNullableBitConsumer extends BaseConsumer {
- /**
- * Instantiate a BitConsumer.
- */
+ /** Instantiate a BitConsumer. */
public NonNullableBitConsumer(BitVector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BlobConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BlobConsumer.java
index e57ecdf9170..d2cf0c7f66c 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BlobConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BlobConsumer.java
@@ -21,12 +21,11 @@
import java.sql.Blob;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.VarBinaryVector;
/**
- * Consumer which consume blob type values from {@link ResultSet}.
- * Write the data to {@link VarBinaryVector}.
+ * Consumer which consume blob type values from {@link ResultSet}. Write the data to {@link
+ * VarBinaryVector}.
*/
public class BlobConsumer extends BaseConsumer {
@@ -34,17 +33,12 @@ public class BlobConsumer extends BaseConsumer {
private final boolean nullable;
- /**
- * Creates a consumer for {@link VarBinaryVector}.
- */
- public static BlobConsumer createConsumer(
- BinaryConsumer delegate, int index, boolean nullable) {
+ /** Creates a consumer for {@link VarBinaryVector}. */
+ public static BlobConsumer createConsumer(BinaryConsumer delegate, int index, boolean nullable) {
return new BlobConsumer(delegate, index, nullable);
}
- /**
- * Instantiate a BlobConsumer.
- */
+ /** Instantiate a BlobConsumer. */
public BlobConsumer(BinaryConsumer delegate, int index, boolean nullable) {
super(null, index);
this.delegate = delegate;
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ClobConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ClobConsumer.java
index a52d9b73b4d..454b25416b8 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ClobConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ClobConsumer.java
@@ -21,21 +21,18 @@
import java.sql.Clob;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.memory.ArrowBuf;
import org.apache.arrow.memory.util.MemoryUtil;
import org.apache.arrow.vector.BitVectorHelper;
import org.apache.arrow.vector.VarCharVector;
/**
- * Consumer which consume clob type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.VarCharVector}.
+ * Consumer which consume clob type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.VarCharVector}.
*/
public abstract class ClobConsumer extends BaseConsumer {
- /**
- * Creates a consumer for {@link VarCharVector}.
- */
+ /** Creates a consumer for {@link VarCharVector}. */
public static ClobConsumer createConsumer(VarCharVector vector, int index, boolean nullable) {
if (nullable) {
return new NullableClobConsumer(vector, index);
@@ -46,9 +43,7 @@ public static ClobConsumer createConsumer(VarCharVector vector, int index, boole
private static final int BUFFER_SIZE = 256;
- /**
- * Instantiate a ClobConsumer.
- */
+ /** Instantiate a ClobConsumer. */
public ClobConsumer(VarCharVector vector, int index) {
super(vector, index);
if (vector != null) {
@@ -63,14 +58,10 @@ public void resetValueVector(VarCharVector vector) {
this.currentIndex = 0;
}
- /**
- * Nullable consumer for clob data.
- */
+ /** Nullable consumer for clob data. */
static class NullableClobConsumer extends ClobConsumer {
-
- /**
- * Instantiate a ClobConsumer.
- */
+
+ /** Instantiate a ClobConsumer. */
public NullableClobConsumer(VarCharVector vector, int index) {
super(vector, index);
}
@@ -97,11 +88,11 @@ public void consume(ResultSet resultSet) throws SQLException {
vector.reallocDataBuffer();
}
MemoryUtil.UNSAFE.copyMemory(
- bytes,
- MemoryUtil.BYTE_ARRAY_BASE_OFFSET,
- null,
- dataBuffer.memoryAddress() + startIndex + totalBytes,
- bytes.length);
+ bytes,
+ MemoryUtil.BYTE_ARRAY_BASE_OFFSET,
+ null,
+ dataBuffer.memoryAddress() + startIndex + totalBytes,
+ bytes.length);
totalBytes += bytes.length;
read += readSize;
@@ -115,14 +106,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for clob data.
- */
+ /** Non-nullable consumer for clob data. */
static class NonNullableClobConsumer extends ClobConsumer {
- /**
- * Instantiate a ClobConsumer.
- */
+ /** Instantiate a ClobConsumer. */
public NonNullableClobConsumer(VarCharVector vector, int index) {
super(vector, index);
}
@@ -148,11 +135,11 @@ public void consume(ResultSet resultSet) throws SQLException {
vector.reallocDataBuffer();
}
MemoryUtil.UNSAFE.copyMemory(
- bytes,
- MemoryUtil.BYTE_ARRAY_BASE_OFFSET,
- null,
- dataBuffer.memoryAddress() + startIndex + totalBytes,
- bytes.length);
+ bytes,
+ MemoryUtil.BYTE_ARRAY_BASE_OFFSET,
+ null,
+ dataBuffer.memoryAddress() + startIndex + totalBytes,
+ bytes.length);
totalBytes += bytes.length;
read += readSize;
@@ -161,7 +148,7 @@ public void consume(ResultSet resultSet) throws SQLException {
BitVectorHelper.setBit(vector.getValidityBuffer(), currentIndex);
vector.setLastSet(currentIndex);
}
-
+
currentIndex++;
}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/CompositeJdbcConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/CompositeJdbcConsumer.java
index e6d780956d5..4e6049b9d83 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/CompositeJdbcConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/CompositeJdbcConsumer.java
@@ -20,7 +20,6 @@
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.adapter.jdbc.JdbcFieldInfo;
import org.apache.arrow.adapter.jdbc.consumer.exceptions.JdbcConsumerException;
import org.apache.arrow.util.AutoCloseables;
@@ -28,17 +27,12 @@
import org.apache.arrow.vector.VectorSchemaRoot;
import org.apache.arrow.vector.types.pojo.ArrowType;
-/**
- * Composite consumer which hold all consumers.
- * It manages the consume and cleanup process.
- */
+/** Composite consumer which hold all consumers. It manages the consume and cleanup process. */
public class CompositeJdbcConsumer implements JdbcConsumer {
private final JdbcConsumer[] consumers;
- /**
- * Construct an instance.
- */
+ /** Construct an instance. */
public CompositeJdbcConsumer(JdbcConsumer[] consumers) {
this.consumers = consumers;
}
@@ -51,9 +45,11 @@ public void consume(ResultSet rs) throws SQLException, IOException {
} catch (Exception e) {
if (consumers[i] instanceof BaseConsumer) {
BaseConsumer consumer = (BaseConsumer) consumers[i];
- JdbcFieldInfo fieldInfo = new JdbcFieldInfo(rs.getMetaData(), consumer.columnIndexInResultSet);
+ JdbcFieldInfo fieldInfo =
+ new JdbcFieldInfo(rs.getMetaData(), consumer.columnIndexInResultSet);
ArrowType arrowType = consumer.vector.getMinorType().getType();
- throw new JdbcConsumerException("Exception while consuming JDBC value", e, fieldInfo, arrowType);
+ throw new JdbcConsumerException(
+ "Exception while consuming JDBC value", e, fieldInfo, arrowType);
} else {
throw e;
}
@@ -70,17 +66,12 @@ public void close() {
} catch (Exception e) {
throw new RuntimeException("Error occurred while releasing resources.", e);
}
-
}
@Override
- public void resetValueVector(ValueVector vector) {
+ public void resetValueVector(ValueVector vector) {}
- }
-
- /**
- * Reset inner consumers through vectors in the vector schema root.
- */
+ /** Reset inner consumers through vectors in the vector schema root. */
public void resetVectorSchemaRoot(VectorSchemaRoot root) {
assert root.getFieldVectors().size() == consumers.length;
for (int i = 0; i < consumers.length; i++) {
@@ -88,4 +79,3 @@ public void resetVectorSchemaRoot(VectorSchemaRoot root) {
}
}
}
-
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DateConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DateConsumer.java
index b9b83daccc2..aa69516526c 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DateConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DateConsumer.java
@@ -22,19 +22,16 @@
import java.sql.SQLException;
import java.util.Calendar;
import java.util.concurrent.TimeUnit;
-
import org.apache.arrow.vector.DateDayVector;
import org.apache.arrow.vector.DateMilliVector;
/**
- * Consumer which consume date type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.DateDayVector}.
+ * Consumer which consume date type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.DateDayVector}.
*/
public class DateConsumer {
- /**
- * Creates a consumer for {@link DateMilliVector}.
- */
+ /** Creates a consumer for {@link DateMilliVector}. */
public static JdbcConsumer createConsumer(
DateDayVector vector, int index, boolean nullable, Calendar calendar) {
if (nullable) {
@@ -44,23 +41,17 @@ public static JdbcConsumer createConsumer(
}
}
- /**
- * Nullable consumer for date.
- */
+ /** Nullable consumer for date. */
static class NullableDateConsumer extends BaseConsumer {
protected final Calendar calendar;
- /**
- * Instantiate a DateConsumer.
- */
+ /** Instantiate a DateConsumer. */
public NullableDateConsumer(DateDayVector vector, int index) {
- this(vector, index, /* calendar */null);
+ this(vector, index, /* calendar */ null);
}
- /**
- * Instantiate a DateConsumer.
- */
+ /** Instantiate a DateConsumer. */
public NullableDateConsumer(DateDayVector vector, int index, Calendar calendar) {
super(vector, index);
this.calendar = calendar;
@@ -68,8 +59,10 @@ public NullableDateConsumer(DateDayVector vector, int index, Calendar calendar)
@Override
public void consume(ResultSet resultSet) throws SQLException {
- Date date = calendar == null ? resultSet.getDate(columnIndexInResultSet) :
- resultSet.getDate(columnIndexInResultSet, calendar);
+ Date date =
+ calendar == null
+ ? resultSet.getDate(columnIndexInResultSet)
+ : resultSet.getDate(columnIndexInResultSet, calendar);
if (!resultSet.wasNull()) {
// for fixed width vectors, we have allocated enough memory proactively,
// so there is no need to call the setSafe method here.
@@ -79,23 +72,17 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for date.
- */
+ /** Non-nullable consumer for date. */
static class NonNullableDateConsumer extends BaseConsumer {
protected final Calendar calendar;
- /**
- * Instantiate a DateConsumer.
- */
+ /** Instantiate a DateConsumer. */
public NonNullableDateConsumer(DateDayVector vector, int index) {
- this(vector, index, /* calendar */null);
+ this(vector, index, /* calendar */ null);
}
- /**
- * Instantiate a DateConsumer.
- */
+ /** Instantiate a DateConsumer. */
public NonNullableDateConsumer(DateDayVector vector, int index, Calendar calendar) {
super(vector, index);
this.calendar = calendar;
@@ -103,8 +90,10 @@ public NonNullableDateConsumer(DateDayVector vector, int index, Calendar calenda
@Override
public void consume(ResultSet resultSet) throws SQLException {
- Date date = calendar == null ? resultSet.getDate(columnIndexInResultSet) :
- resultSet.getDate(columnIndexInResultSet, calendar);
+ Date date =
+ calendar == null
+ ? resultSet.getDate(columnIndexInResultSet)
+ : resultSet.getDate(columnIndexInResultSet, calendar);
// for fixed width vectors, we have allocated enough memory proactively,
// so there is no need to call the setSafe method here.
vector.set(currentIndex, Math.toIntExact(TimeUnit.MILLISECONDS.toDays(date.getTime())));
@@ -112,5 +101,3 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
}
-
-
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/Decimal256Consumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/Decimal256Consumer.java
index ad00d9b5a24..c670a4248b6 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/Decimal256Consumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/Decimal256Consumer.java
@@ -21,12 +21,11 @@
import java.math.RoundingMode;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.Decimal256Vector;
/**
- * Consumer which consume decimal type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.Decimal256Vector}.
+ * Consumer which consume decimal type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.Decimal256Vector}.
*/
public abstract class Decimal256Consumer extends BaseConsumer {
private final RoundingMode bigDecimalRoundingMode;
@@ -36,7 +35,7 @@ public abstract class Decimal256Consumer extends BaseConsumer
* Constructs a new consumer.
*
* @param vector the underlying vector for the consumer.
- * @param index the column id for the consumer.
+ * @param index the column id for the consumer.
*/
public Decimal256Consumer(Decimal256Vector vector, int index) {
this(vector, index, null);
@@ -44,27 +43,23 @@ public Decimal256Consumer(Decimal256Vector vector, int index) {
/**
* Constructs a new consumer, with optional coercibility.
+ *
* @param vector the underlying vector for the consumer.
* @param index the column index for the consumer.
- * @param 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).
+ * @param 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).
*/
- public Decimal256Consumer(Decimal256Vector vector, int index, RoundingMode bigDecimalRoundingMode) {
+ public Decimal256Consumer(
+ Decimal256Vector vector, int index, RoundingMode bigDecimalRoundingMode) {
super(vector, index);
this.bigDecimalRoundingMode = bigDecimalRoundingMode;
this.scale = vector.getScale();
}
- /**
- * Creates a consumer for {@link Decimal256Vector}.
- */
+ /** Creates a consumer for {@link Decimal256Vector}. */
public static JdbcConsumer createConsumer(
- Decimal256Vector vector,
- int index,
- boolean nullable,
- RoundingMode bigDecimalRoundingMode
- ) {
+ Decimal256Vector vector, int index, boolean nullable, RoundingMode bigDecimalRoundingMode) {
if (nullable) {
return new NullableDecimal256Consumer(vector, index, bigDecimalRoundingMode);
} else {
@@ -79,16 +74,12 @@ protected void set(BigDecimal value) {
vector.set(currentIndex, value);
}
-
- /**
- * Consumer for nullable decimal.
- */
+ /** Consumer for nullable decimal. */
static class NullableDecimal256Consumer extends Decimal256Consumer {
- /**
- * Instantiate a Decimal256Consumer.
- */
- public NullableDecimal256Consumer(Decimal256Vector vector, int index, RoundingMode bigDecimalRoundingMode) {
+ /** Instantiate a Decimal256Consumer. */
+ public NullableDecimal256Consumer(
+ Decimal256Vector vector, int index, RoundingMode bigDecimalRoundingMode) {
super(vector, index, bigDecimalRoundingMode);
}
@@ -104,15 +95,12 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Consumer for non-nullable decimal.
- */
+ /** Consumer for non-nullable decimal. */
static class NonNullableDecimal256Consumer extends Decimal256Consumer {
- /**
- * Instantiate a Decimal256Consumer.
- */
- public NonNullableDecimal256Consumer(Decimal256Vector vector, int index, RoundingMode bigDecimalRoundingMode) {
+ /** Instantiate a Decimal256Consumer. */
+ public NonNullableDecimal256Consumer(
+ Decimal256Vector vector, int index, RoundingMode bigDecimalRoundingMode) {
super(vector, index, bigDecimalRoundingMode);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DecimalConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DecimalConsumer.java
index bed96dda8b6..034cdf14ae6 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DecimalConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DecimalConsumer.java
@@ -21,12 +21,11 @@
import java.math.RoundingMode;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.DecimalVector;
/**
- * Consumer which consume decimal type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.DecimalVector}.
+ * Consumer which consume decimal type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.DecimalVector}.
*/
public abstract class DecimalConsumer extends BaseConsumer {
private final RoundingMode bigDecimalRoundingMode;
@@ -36,7 +35,7 @@ public abstract class DecimalConsumer extends BaseConsumer {
* Constructs a new consumer.
*
* @param vector the underlying vector for the consumer.
- * @param index the column id for the consumer.
+ * @param index the column id for the consumer.
*/
public DecimalConsumer(DecimalVector vector, int index) {
this(vector, index, null);
@@ -44,11 +43,12 @@ public DecimalConsumer(DecimalVector vector, int index) {
/**
* Constructs a new consumer, with optional coercibility.
+ *
* @param vector the underlying vector for the consumer.
* @param index the column index for the consumer.
- * @param 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).
+ * @param 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).
*/
public DecimalConsumer(DecimalVector vector, int index, RoundingMode bigDecimalRoundingMode) {
super(vector, index);
@@ -56,15 +56,9 @@ public DecimalConsumer(DecimalVector vector, int index, RoundingMode bigDecimalR
this.scale = vector.getScale();
}
- /**
- * Creates a consumer for {@link DecimalVector}.
- */
+ /** Creates a consumer for {@link DecimalVector}. */
public static JdbcConsumer createConsumer(
- DecimalVector vector,
- int index,
- boolean nullable,
- RoundingMode bigDecimalRoundingMode
- ) {
+ DecimalVector vector, int index, boolean nullable, RoundingMode bigDecimalRoundingMode) {
if (nullable) {
return new NullableDecimalConsumer(vector, index, bigDecimalRoundingMode);
} else {
@@ -79,16 +73,12 @@ protected void set(BigDecimal value) {
vector.set(currentIndex, value);
}
-
- /**
- * Consumer for nullable decimal.
- */
+ /** Consumer for nullable decimal. */
static class NullableDecimalConsumer extends DecimalConsumer {
- /**
- * Instantiate a DecimalConsumer.
- */
- public NullableDecimalConsumer(DecimalVector vector, int index, RoundingMode bigDecimalRoundingMode) {
+ /** Instantiate a DecimalConsumer. */
+ public NullableDecimalConsumer(
+ DecimalVector vector, int index, RoundingMode bigDecimalRoundingMode) {
super(vector, index, bigDecimalRoundingMode);
}
@@ -104,15 +94,12 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Consumer for non-nullable decimal.
- */
+ /** Consumer for non-nullable decimal. */
static class NonNullableDecimalConsumer extends DecimalConsumer {
- /**
- * Instantiate a DecimalConsumer.
- */
- public NonNullableDecimalConsumer(DecimalVector vector, int index, RoundingMode bigDecimalRoundingMode) {
+ /** Instantiate a DecimalConsumer. */
+ public NonNullableDecimalConsumer(
+ DecimalVector vector, int index, RoundingMode bigDecimalRoundingMode) {
super(vector, index, bigDecimalRoundingMode);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DoubleConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DoubleConsumer.java
index e3db95d1535..79cb4f65bb6 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DoubleConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/DoubleConsumer.java
@@ -19,19 +19,17 @@
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.Float8Vector;
/**
- * Consumer which consume double type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.Float8Vector}.
+ * Consumer which consume double type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.Float8Vector}.
*/
public class DoubleConsumer {
- /**
- * Creates a consumer for {@link Float8Vector}.
- */
- public static JdbcConsumer createConsumer(Float8Vector vector, int index, boolean nullable) {
+ /** Creates a consumer for {@link Float8Vector}. */
+ public static JdbcConsumer createConsumer(
+ Float8Vector vector, int index, boolean nullable) {
if (nullable) {
return new NullableDoubleConsumer(vector, index);
} else {
@@ -39,14 +37,10 @@ public static JdbcConsumer createConsumer(Float8Vector vector, int
}
}
- /**
- * Nullable double consumer.
- */
+ /** Nullable double consumer. */
static class NullableDoubleConsumer extends BaseConsumer {
- /**
- * Instantiate a DoubleConsumer.
- */
+ /** Instantiate a DoubleConsumer. */
public NullableDoubleConsumer(Float8Vector vector, int index) {
super(vector, index);
}
@@ -63,14 +57,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable double consumer.
- */
+ /** Non-nullable double consumer. */
static class NonNullableDoubleConsumer extends BaseConsumer {
- /**
- * Instantiate a DoubleConsumer.
- */
+ /** Instantiate a DoubleConsumer. */
public NonNullableDoubleConsumer(Float8Vector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/FloatConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/FloatConsumer.java
index 830348fe94c..70b6e50e483 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/FloatConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/FloatConsumer.java
@@ -19,19 +19,17 @@
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.Float4Vector;
/**
- * Consumer which consume float type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.Float4Vector}.
+ * Consumer which consume float type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.Float4Vector}.
*/
public class FloatConsumer {
- /**
- * Creates a consumer for {@link Float4Vector}.
- */
- public static JdbcConsumer createConsumer(Float4Vector vector, int index, boolean nullable) {
+ /** Creates a consumer for {@link Float4Vector}. */
+ public static JdbcConsumer createConsumer(
+ Float4Vector vector, int index, boolean nullable) {
if (nullable) {
return new NullableFloatConsumer(vector, index);
} else {
@@ -39,14 +37,10 @@ public static JdbcConsumer createConsumer(Float4Vector vector, int
}
}
- /**
- * Nullable float consumer.
- */
+ /** Nullable float consumer. */
static class NullableFloatConsumer extends BaseConsumer {
- /**
- * Instantiate a FloatConsumer.
- */
+ /** Instantiate a FloatConsumer. */
public NullableFloatConsumer(Float4Vector vector, int index) {
super(vector, index);
}
@@ -63,14 +57,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable float consumer.
- */
+ /** Non-nullable float consumer. */
static class NonNullableFloatConsumer extends BaseConsumer {
- /**
- * Instantiate a FloatConsumer.
- */
+ /** Instantiate a FloatConsumer. */
public NonNullableFloatConsumer(Float4Vector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/IntConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/IntConsumer.java
index 4e537d682ff..883cc1b8ffa 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/IntConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/IntConsumer.java
@@ -19,19 +19,17 @@
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.IntVector;
/**
- * Consumer which consume int type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.IntVector}.
+ * Consumer which consume int type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.IntVector}.
*/
public class IntConsumer {
- /**
- * Creates a consumer for {@link IntVector}.
- */
- public static JdbcConsumer createConsumer(IntVector vector, int index, boolean nullable) {
+ /** Creates a consumer for {@link IntVector}. */
+ public static JdbcConsumer createConsumer(
+ IntVector vector, int index, boolean nullable) {
if (nullable) {
return new NullableIntConsumer(vector, index);
} else {
@@ -39,14 +37,10 @@ public static JdbcConsumer createConsumer(IntVector vector, int index
}
}
- /**
- * Nullable consumer for int.
- */
+ /** Nullable consumer for int. */
static class NullableIntConsumer extends BaseConsumer {
- /**
- * Instantiate a IntConsumer.
- */
+ /** Instantiate a IntConsumer. */
public NullableIntConsumer(IntVector vector, int index) {
super(vector, index);
}
@@ -63,14 +57,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for int.
- */
+ /** Non-nullable consumer for int. */
static class NonNullableIntConsumer extends BaseConsumer {
- /**
- * Instantiate a IntConsumer.
- */
+ /** Instantiate a IntConsumer. */
public NonNullableIntConsumer(IntVector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/JdbcConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/JdbcConsumer.java
index 480dfe3a1c5..4d20e27d1d6 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/JdbcConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/JdbcConsumer.java
@@ -20,27 +20,21 @@
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.ValueVector;
/**
* An abstraction that is used to consume values from {@link ResultSet}.
+ *
* @param The vector within consumer or its delegate, used for partially consume purpose.
*/
public interface JdbcConsumer extends AutoCloseable {
- /**
- * Consume a specific type value from {@link ResultSet} and write it to vector.
- */
+ /** Consume a specific type value from {@link ResultSet} and write it to vector. */
void consume(ResultSet resultSet) throws SQLException, IOException;
- /**
- * Close this consumer, do some clean work such as clear reuse ArrowBuf.
- */
+ /** Close this consumer, do some clean work such as clear reuse ArrowBuf. */
void close() throws Exception;
- /**
- * Reset the vector within consumer for partial read purpose.
- */
+ /** Reset the vector within consumer for partial read purpose. */
void resetValueVector(T vector);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/MapConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/MapConsumer.java
index 07a071bfc09..b556c14e9e6 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/MapConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/MapConsumer.java
@@ -17,43 +17,37 @@
package org.apache.arrow.adapter.jdbc.consumer;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Map;
-
import org.apache.arrow.memory.ArrowBuf;
import org.apache.arrow.memory.BufferAllocator;
import org.apache.arrow.vector.complex.MapVector;
import org.apache.arrow.vector.complex.impl.UnionMapWriter;
import org.apache.arrow.vector.util.ObjectMapperFactory;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
/**
- * Consumer which consume map type values from {@link ResultSet}.
- * Write the data into {@link org.apache.arrow.vector.complex.MapVector}.
+ * Consumer which consume map type values from {@link ResultSet}. Write the data into {@link
+ * org.apache.arrow.vector.complex.MapVector}.
*/
public class MapConsumer extends BaseConsumer {
-
private final UnionMapWriter writer;
private final ObjectMapper objectMapper = ObjectMapperFactory.newObjectMapper();
- private final TypeReference> typeReference = new TypeReference>() {};
+ private final TypeReference> typeReference =
+ new TypeReference>() {};
private int currentRow;
- /**
- * Creates a consumer for {@link MapVector}.
- */
+ /** Creates a consumer for {@link MapVector}. */
public static MapConsumer createConsumer(MapVector mapVector, int index, boolean nullable) {
return new MapConsumer(mapVector, index);
}
- /**
- * Instantiate a MapConsumer.
- */
+ /** Instantiate a MapConsumer. */
public MapConsumer(MapVector vector, int index) {
super(vector, index);
writer = vector.getWriter();
@@ -69,7 +63,8 @@ public void consume(ResultSet resultSet) throws SQLException, IOException {
} else if (map instanceof Map) {
writeJavaMapIntoVector((Map) map);
} else {
- throw new IllegalArgumentException("Unknown type of map type column from JDBC " + map.getClass().getName());
+ throw new IllegalArgumentException(
+ "Unknown type of map type column from JDBC " + map.getClass().getName());
}
} else {
writer.writeNull();
@@ -79,26 +74,25 @@ public void consume(ResultSet resultSet) throws SQLException, IOException {
private void writeJavaMapIntoVector(Map map) {
BufferAllocator allocator = vector.getAllocator();
writer.startMap();
- map.forEach((key, value) -> {
- byte[] keyBytes = key.getBytes(StandardCharsets.UTF_8);
- byte[] valueBytes = value != null ? value.getBytes(StandardCharsets.UTF_8) : null;
- try (
- ArrowBuf keyBuf = allocator.buffer(keyBytes.length);
- ArrowBuf valueBuf = valueBytes != null ? allocator.buffer(valueBytes.length) : null;
- ) {
- writer.startEntry();
- keyBuf.writeBytes(keyBytes);
- writer.key().varChar().writeVarChar(0, keyBytes.length, keyBuf);
- if (valueBytes != null) {
- valueBuf.writeBytes(valueBytes);
- writer.value().varChar().writeVarChar(0, valueBytes.length, valueBuf);
- } else {
- writer.value().varChar().writeNull();
- }
- writer.endEntry();
- }
- });
+ map.forEach(
+ (key, value) -> {
+ byte[] keyBytes = key.getBytes(StandardCharsets.UTF_8);
+ byte[] valueBytes = value != null ? value.getBytes(StandardCharsets.UTF_8) : null;
+ try (ArrowBuf keyBuf = allocator.buffer(keyBytes.length);
+ ArrowBuf valueBuf =
+ valueBytes != null ? allocator.buffer(valueBytes.length) : null; ) {
+ writer.startEntry();
+ keyBuf.writeBytes(keyBytes);
+ writer.key().varChar().writeVarChar(0, keyBytes.length, keyBuf);
+ if (valueBytes != null) {
+ valueBuf.writeBytes(valueBytes);
+ writer.value().varChar().writeVarChar(0, valueBytes.length, valueBuf);
+ } else {
+ writer.value().varChar().writeNull();
+ }
+ writer.endEntry();
+ }
+ });
writer.endMap();
}
}
-
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/NullConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/NullConsumer.java
index a79a029f45d..5b9aee84212 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/NullConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/NullConsumer.java
@@ -19,12 +19,11 @@
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.NullVector;
/**
- * Consumer which consume null type values from ResultSet.
- * Corresponding to {@link org.apache.arrow.vector.NullVector}.
+ * Consumer which consume null type values from ResultSet. Corresponding to {@link
+ * org.apache.arrow.vector.NullVector}.
*/
public class NullConsumer extends BaseConsumer {
@@ -33,6 +32,5 @@ public NullConsumer(NullVector vector) {
}
@Override
- public void consume(ResultSet resultSet) throws SQLException {
- }
+ public void consume(ResultSet resultSet) throws SQLException {}
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/SmallIntConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/SmallIntConsumer.java
index 2edb3605b17..0fe3eb3d2df 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/SmallIntConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/SmallIntConsumer.java
@@ -19,19 +19,17 @@
import java.sql.ResultSet;
import java.sql.SQLException;
-
import org.apache.arrow.vector.SmallIntVector;
/**
- * Consumer which consume smallInt type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.SmallIntVector}.
+ * Consumer which consume smallInt type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.SmallIntVector}.
*/
public class SmallIntConsumer {
- /**
- * Creates a consumer for {@link SmallIntVector}.
- */
- public static BaseConsumer createConsumer(SmallIntVector vector, int index, boolean nullable) {
+ /** Creates a consumer for {@link SmallIntVector}. */
+ public static BaseConsumer createConsumer(
+ SmallIntVector vector, int index, boolean nullable) {
if (nullable) {
return new NullableSmallIntConsumer(vector, index);
} else {
@@ -39,14 +37,10 @@ public static BaseConsumer createConsumer(SmallIntVector vector,
}
}
- /**
- * Nullable consumer for small int.
- */
+ /** Nullable consumer for small int. */
static class NullableSmallIntConsumer extends BaseConsumer {
- /**
- * Instantiate a SmallIntConsumer.
- */
+ /** Instantiate a SmallIntConsumer. */
public NullableSmallIntConsumer(SmallIntVector vector, int index) {
super(vector, index);
}
@@ -63,14 +57,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for small int.
- */
+ /** Non-nullable consumer for small int. */
static class NonNullableSmallIntConsumer extends BaseConsumer {
- /**
- * Instantiate a SmallIntConsumer.
- */
+ /** Instantiate a SmallIntConsumer. */
public NonNullableSmallIntConsumer(SmallIntVector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimeConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimeConsumer.java
index 4fa15ad7903..d5b647a6189 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimeConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimeConsumer.java
@@ -21,20 +21,17 @@
import java.sql.SQLException;
import java.sql.Time;
import java.util.Calendar;
-
import org.apache.arrow.vector.TimeMilliVector;
/**
- * Consumer which consume time type values from {@link ResultSet}.
- * Write the data to {@link org.apache.arrow.vector.TimeMilliVector}.
+ * Consumer which consume time type values from {@link ResultSet}. Write the data to {@link
+ * org.apache.arrow.vector.TimeMilliVector}.
*/
public abstract class TimeConsumer {
- /**
- * Creates a consumer for {@link TimeMilliVector}.
- */
+ /** Creates a consumer for {@link TimeMilliVector}. */
public static JdbcConsumer createConsumer(
- TimeMilliVector vector, int index, boolean nullable, Calendar calendar) {
+ TimeMilliVector vector, int index, boolean nullable, Calendar calendar) {
if (nullable) {
return new NullableTimeConsumer(vector, index, calendar);
} else {
@@ -42,23 +39,17 @@ public static JdbcConsumer createConsumer(
}
}
- /**
- * Nullable consumer for {@link TimeMilliVector}.
- */
+ /** Nullable consumer for {@link TimeMilliVector}. */
static class NullableTimeConsumer extends BaseConsumer {
protected final Calendar calendar;
- /**
- * Instantiate a TimeConsumer.
- */
+ /** Instantiate a TimeConsumer. */
public NullableTimeConsumer(TimeMilliVector vector, int index) {
- this(vector, index, /* calendar */null);
+ this(vector, index, /* calendar */ null);
}
- /**
- * Instantiate a TimeConsumer.
- */
+ /** Instantiate a TimeConsumer. */
public NullableTimeConsumer(TimeMilliVector vector, int index, Calendar calendar) {
super(vector, index);
this.calendar = calendar;
@@ -66,8 +57,10 @@ public NullableTimeConsumer(TimeMilliVector vector, int index, Calendar calendar
@Override
public void consume(ResultSet resultSet) throws SQLException {
- Time time = calendar == null ? resultSet.getTime(columnIndexInResultSet) :
- resultSet.getTime(columnIndexInResultSet, calendar);
+ Time time =
+ calendar == null
+ ? resultSet.getTime(columnIndexInResultSet)
+ : resultSet.getTime(columnIndexInResultSet, calendar);
if (!resultSet.wasNull()) {
// for fixed width vectors, we have allocated enough memory proactively,
// so there is no need to call the setSafe method here.
@@ -77,23 +70,17 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for {@link TimeMilliVector}.
- */
+ /** Non-nullable consumer for {@link TimeMilliVector}. */
static class NonNullableTimeConsumer extends BaseConsumer {
protected final Calendar calendar;
- /**
- * Instantiate a TimeConsumer.
- */
+ /** Instantiate a TimeConsumer. */
public NonNullableTimeConsumer(TimeMilliVector vector, int index) {
- this(vector, index, /* calendar */null);
+ this(vector, index, /* calendar */ null);
}
- /**
- * Instantiate a TimeConsumer.
- */
+ /** Instantiate a TimeConsumer. */
public NonNullableTimeConsumer(TimeMilliVector vector, int index, Calendar calendar) {
super(vector, index);
this.calendar = calendar;
@@ -101,8 +88,10 @@ public NonNullableTimeConsumer(TimeMilliVector vector, int index, Calendar calen
@Override
public void consume(ResultSet resultSet) throws SQLException {
- Time time = calendar == null ? resultSet.getTime(columnIndexInResultSet) :
- resultSet.getTime(columnIndexInResultSet, calendar);
+ Time time =
+ calendar == null
+ ? resultSet.getTime(columnIndexInResultSet)
+ : resultSet.getTime(columnIndexInResultSet, calendar);
// for fixed width vectors, we have allocated enough memory proactively,
// so there is no need to call the setSafe method here.
vector.set(currentIndex, (int) time.getTime());
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampConsumer.java
index 3351e7e78a7..0b96092465c 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampConsumer.java
@@ -20,20 +20,17 @@
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
-
import org.apache.arrow.vector.TimeStampMilliVector;
/**
- * Consumer which consume timestamp type values from {@link ResultSet}.
- * Write the data to {@link TimeStampMilliVector}.
+ * Consumer which consume timestamp type values from {@link ResultSet}. Write the data to {@link
+ * TimeStampMilliVector}.
*/
public abstract class TimestampConsumer {
- /**
- * Creates a consumer for {@link TimeStampMilliVector}.
- */
+ /** Creates a consumer for {@link TimeStampMilliVector}. */
public static JdbcConsumer createConsumer(
- TimeStampMilliVector vector, int index, boolean nullable) {
+ TimeStampMilliVector vector, int index, boolean nullable) {
if (nullable) {
return new NullableTimestampConsumer(vector, index);
} else {
@@ -41,14 +38,10 @@ public static JdbcConsumer createConsumer(
}
}
- /**
- * Nullable consumer for timestamp.
- */
+ /** Nullable consumer for timestamp. */
static class NullableTimestampConsumer extends BaseConsumer {
- /**
- * Instantiate a TimestampConsumer.
- */
+ /** Instantiate a TimestampConsumer. */
public NullableTimestampConsumer(TimeStampMilliVector vector, int index) {
super(vector, index);
}
@@ -65,14 +58,10 @@ public void consume(ResultSet resultSet) throws SQLException {
}
}
- /**
- * Non-nullable consumer for timestamp.
- */
+ /** Non-nullable consumer for timestamp. */
static class NonNullableTimestampConsumer extends BaseConsumer {
- /**
- * Instantiate a TimestampConsumer.
- */
+ /** Instantiate a TimestampConsumer. */
public NonNullableTimestampConsumer(TimeStampMilliVector vector, int index) {
super(vector, index);
}
diff --git a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampTZConsumer.java b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampTZConsumer.java
index f08671f0be6..c55b6669326 100644
--- a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampTZConsumer.java
+++ b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/TimestampTZConsumer.java
@@ -21,18 +21,15 @@
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.Calendar;
-
import org.apache.arrow.util.Preconditions;
import org.apache.arrow.vector.TimeStampMilliTZVector;
/**
- * Consumer which consume timestamp (with time zone) type values from {@link ResultSet}.
- * Write the data to {@link TimeStampMilliTZVector}.
+ * Consumer which consume timestamp (with time zone) type values from {@link ResultSet}. Write the
+ * data to {@link TimeStampMilliTZVector}.
*/
public class TimestampTZConsumer {
- /**
- * Creates a consumer for {@link TimeStampMilliTZVector}.
- */
+ /** Creates a consumer for {@link TimeStampMilliTZVector}. */
public static JdbcConsumer