This is an automated email from the ASF dual-hosted git repository.
lidavidm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow.git
The following commit(s) were added to refs/heads/main by this push:
new cf1b265f44 GH-38930: [Java] Fix spelling (#38931)
cf1b265f44 is described below
commit cf1b265f4481f1a42ce8362db82c377fb659a363
Author: Josh Soref <[email protected]>
AuthorDate: Thu Dec 14 09:36:48 2023 -0500
GH-38930: [Java] Fix spelling (#38931)
### Rationale for this change
### What changes are included in this PR?
Spelling fixes to java/
### Are these changes tested?
### Are there any user-facing changes?
* Closes: #38930
Authored-by: Josh Soref <[email protected]>
Signed-off-by: David Li <[email protected]>
---
.../src/main/java/org/apache/arrow/AvroToArrow.java | 12 ++++++------
.../arrow/adapter/jdbc/ArrowVectorIterator.java | 2 +-
.../org/apache/arrow/adapter/jdbc/JdbcFieldInfo.java | 2 +-
.../org/apache/arrow/adapter/jdbc/JdbcToArrow.java | 4 ++--
.../apache/arrow/adapter/jdbc/JdbcToArrowConfig.java | 2 +-
.../arrow/adapter/jdbc/AbstractJdbcToArrowTest.java | 20 ++++++++++----------
.../arrow/adapter/jdbc/UnreliableMetaDataTest.java | 2 +-
.../arrow/adapter/jdbc/h2/JdbcAliasToArrowTest.java | 2 +-
java/c/src/main/java/org/apache/arrow/c/Data.java | 2 +-
.../src/main/java/org/apache/arrow/c/NativeUtil.java | 4 ++--
.../org/apache/arrow/vector/StructVectorLoader.java | 2 +-
.../test/java/org/apache/arrow/c/DictionaryTest.java | 2 +-
.../arrow/compression/TestCompressionCodec.java | 2 +-
java/dataset/src/main/cpp/jni_util.cc | 6 +++---
java/dataset/src/main/cpp/jni_wrapper.cc | 4 ++--
.../org/apache/arrow/dataset/jni/JniWrapper.java | 2 +-
.../apache/arrow/dataset/substrait/JniWrapper.java | 2 +-
.../apache/arrow/flight/OutboundStreamListener.java | 2 +-
.../arrow/flight/auth2/ClientHandshakeWrapper.java | 2 +-
.../arrow/driver/jdbc/ArrowDatabaseMetadata.java | 10 +++++-----
.../jdbc/client/ArrowFlightSqlClientHandler.java | 6 +++---
.../driver/jdbc/utils/AvaticaParameterBinder.java | 2 +-
.../jdbc/utils/VectorSchemaRootTransformer.java | 4 ++--
.../arrow/driver/jdbc/ArrowFlightJdbcDriverTest.java | 6 +++---
.../driver/jdbc/utils/MockFlightSqlProducer.java | 2 +-
.../arrow/flight/sql/FlightSqlColumnMetadata.java | 8 ++++----
.../org/apache/arrow/flight/sql/util/TableRef.java | 2 +-
.../apache/arrow/gandiva/evaluator/JniLoader.java | 6 +++---
.../org/apache/arrow/gandiva/expression/InNode.java | 8 ++++----
.../apache/arrow/memory/AllocationReservation.java | 2 +-
.../main/java/org/apache/arrow/memory/ArrowBuf.java | 2 +-
.../src/main/codegen/templates/BaseWriter.java | 4 ++++
.../src/main/codegen/templates/DenseUnionVector.java | 2 +-
.../apache/arrow/vector/BaseFixedWidthVector.java | 4 ++--
.../arrow/vector/BaseLargeVariableWidthVector.java | 2 +-
.../apache/arrow/vector/BaseVariableWidthVector.java | 2 +-
.../org/apache/arrow/vector/Decimal256Vector.java | 2 +-
.../java/org/apache/arrow/vector/DecimalVector.java | 4 ++--
.../org/apache/arrow/vector/ExtensionTypeVector.java | 2 +-
.../arrow/vector/IntervalMonthDayNanoVector.java | 2 +-
.../java/org/apache/arrow/vector/VectorLoader.java | 2 +-
.../apache/arrow/vector/complex/StructVector.java | 4 ++--
.../arrow/vector/complex/impl/ComplexWriterImpl.java | 2 +-
.../complex/impl/NullableStructWriterFactory.java | 2 +-
.../vector/complex/impl/StructOrListWriterImpl.java | 11 +++++++++++
.../org/apache/arrow/vector/util/DecimalUtility.java | 4 ++--
.../org/apache/arrow/vector/util/VectorAppender.java | 2 +-
.../vector/validate/ValidateVectorTypeVisitor.java | 2 +-
.../apache/arrow/vector/TestDecimal256Vector.java | 2 +-
.../apache/arrow/vector/TestDenseUnionVector.java | 6 +++---
.../org/apache/arrow/vector/TestVectorReAlloc.java | 8 ++++----
.../arrow/vector/ipc/MessageSerializerTest.java | 4 ++--
.../arrow/vector/types/pojo/TestExtensionType.java | 2 +-
53 files changed, 112 insertions(+), 97 deletions(-)
diff --git a/java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrow.java
b/java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrow.java
index 9fb5ce291f..33f1803937 100644
--- a/java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrow.java
+++ b/java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrow.java
@@ -39,9 +39,9 @@ public class AvroToArrow {
*/
static VectorSchemaRoot avroToArrow(Schema schema, Decoder decoder,
AvroToArrowConfig config)
throws IOException {
- Preconditions.checkNotNull(schema, "Avro schema object can not be null");
- Preconditions.checkNotNull(decoder, "Avro decoder object can not be null");
- Preconditions.checkNotNull(config, "config can not be null");
+ Preconditions.checkNotNull(schema, "Avro schema object cannot be null");
+ Preconditions.checkNotNull(decoder, "Avro decoder object cannot be null");
+ Preconditions.checkNotNull(config, "config cannot be null");
return AvroToArrowUtils.avroToArrowVectors(schema, decoder, config);
}
@@ -58,9 +58,9 @@ public class AvroToArrow {
Decoder decoder,
AvroToArrowConfig config) throws IOException {
- Preconditions.checkNotNull(schema, "Avro schema object can not be null");
- Preconditions.checkNotNull(decoder, "Avro decoder object can not be null");
- Preconditions.checkNotNull(config, "config can not be null");
+ Preconditions.checkNotNull(schema, "Avro schema object cannot be null");
+ Preconditions.checkNotNull(decoder, "Avro decoder object cannot be null");
+ Preconditions.checkNotNull(config, "config cannot be null");
return AvroToArrowVectorIterator.create(decoder, schema, config);
}
diff --git
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/ArrowVectorIterator.java
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/ArrowVectorIterator.java
index 6e789009dd..632c7c474b 100644
---
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/ArrowVectorIterator.java
+++
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/ArrowVectorIterator.java
@@ -53,7 +53,7 @@ public class ArrowVectorIterator implements
Iterator<VectorSchemaRoot>, AutoClos
private final int targetBatchSize;
- // This is used to track whether the ResultSet has been fully read, and is
needed spcifically for cases where there
+ // This is used to track whether the ResultSet has been fully read, and is
needed specifically for cases where there
// is a ResultSet having zero rows (empty):
private boolean readComplete = false;
diff --git
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcFieldInfo.java
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcFieldInfo.java
index 97ca8f27ce..d16964ea14 100644
---
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcFieldInfo.java
+++
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcFieldInfo.java
@@ -129,7 +129,7 @@ public class JdbcFieldInfo {
/**
* Builds a <code>JdbcFieldInfo</code> from the corresponding row from a
{@link java.sql.DatabaseMetaData#getColumns}
- * ResulSet.
+ * ResultSet.
*
* @param rs The {@link java.sql.ResultSet} to get the field information
from.
* @throws SQLException If the column information cannot be retrieved.
diff --git
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrow.java
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrow.java
index daee64d930..246451b5b2 100644
---
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrow.java
+++
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrow.java
@@ -77,7 +77,7 @@ public class JdbcToArrow {
ResultSet resultSet,
BufferAllocator allocator)
throws SQLException, IOException {
- Preconditions.checkNotNull(allocator, "Memory Allocator object can not be
null");
+ Preconditions.checkNotNull(allocator, "Memory Allocator object cannot be
null");
JdbcToArrowConfig config =
new JdbcToArrowConfig(allocator, JdbcToArrowUtils.getUtcCalendar());
@@ -96,7 +96,7 @@ public class JdbcToArrow {
ResultSet resultSet,
JdbcToArrowConfig config)
throws SQLException, IOException {
- Preconditions.checkNotNull(resultSet, "JDBC ResultSet object can not be
null");
+ Preconditions.checkNotNull(resultSet, "JDBC ResultSet object cannot be
null");
Preconditions.checkNotNull(config, "The configuration cannot be null");
return ArrowVectorIterator.create(resultSet, config);
}
diff --git
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfig.java
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfig.java
index e23bad54af..68851f4a98 100644
---
a/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfig.java
+++
b/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/JdbcToArrowConfig.java
@@ -121,7 +121,7 @@ public final class JdbcToArrowConfig {
* @param reuseVectorSchemaRoot Whether to reuse the vector schema root for
each data load.
* @param arraySubTypesByColumnIndex The type of the JDBC array at the
column index (1-based).
* @param arraySubTypesByColumnName The type of the JDBC array at the
column name.
- * @param targetBatchSize The target batch size to be used in preallcation
of the resulting vectors.
+ * @param targetBatchSize The target batch size to be used in preallocation
of the resulting vectors.
* @param jdbcToArrowTypeConverter The function that maps JDBC field type
information to arrow type. If set to null,
* the default mapping will be used, which
is defined as:
* <ul>
diff --git
a/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/AbstractJdbcToArrowTest.java
b/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/AbstractJdbcToArrowTest.java
index dc36ef9f82..88a66a31aa 100644
---
a/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/AbstractJdbcToArrowTest.java
+++
b/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/AbstractJdbcToArrowTest.java
@@ -183,7 +183,7 @@ public abstract class AbstractJdbcToArrowTest {
*/
public VectorSchemaRoot sqlToArrow(Connection connection, String query,
BufferAllocator allocator)
throws SQLException, IOException {
- Preconditions.checkNotNull(allocator, "Memory allocator object can not be
null");
+ Preconditions.checkNotNull(allocator, "Memory allocator object cannot be
null");
JdbcToArrowConfig config = new JdbcToArrowConfigBuilder(allocator,
JdbcToArrowUtils.getUtcCalendar())
.setArraySubTypeByColumnNameMap(ARRAY_SUB_TYPE_BY_COLUMN_NAME_MAP)
@@ -212,8 +212,8 @@ public abstract class AbstractJdbcToArrowTest {
BufferAllocator allocator,
Calendar calendar) throws SQLException, IOException {
- Preconditions.checkNotNull(allocator, "Memory allocator object can not be
null");
- Preconditions.checkNotNull(calendar, "Calendar object can not be null");
+ Preconditions.checkNotNull(allocator, "Memory allocator object cannot be
null");
+ Preconditions.checkNotNull(calendar, "Calendar object cannot be null");
JdbcToArrowConfig config = new JdbcToArrowConfigBuilder(allocator,
calendar)
.setArraySubTypeByColumnNameMap(ARRAY_SUB_TYPE_BY_COLUMN_NAME_MAP)
@@ -237,8 +237,8 @@ public abstract class AbstractJdbcToArrowTest {
*/
public static VectorSchemaRoot sqlToArrow(Connection connection, String
query, JdbcToArrowConfig config)
throws SQLException, IOException {
- Preconditions.checkNotNull(connection, "JDBC connection object can not be
null");
- Preconditions.checkArgument(query != null && query.length() > 0, "SQL
query can not be null or empty");
+ Preconditions.checkNotNull(connection, "JDBC connection object cannot be
null");
+ Preconditions.checkArgument(query != null && query.length() > 0, "SQL
query cannot be null or empty");
try (Statement stmt = connection.createStatement()) {
return sqlToArrow(stmt.executeQuery(query), config);
@@ -256,7 +256,7 @@ public abstract class AbstractJdbcToArrowTest {
* @throws SQLException on error
*/
public static VectorSchemaRoot sqlToArrow(ResultSet resultSet) throws
SQLException, IOException {
- Preconditions.checkNotNull(resultSet, "JDBC ResultSet object can not be
null");
+ Preconditions.checkNotNull(resultSet, "JDBC ResultSet object cannot be
null");
return sqlToArrow(resultSet, JdbcToArrowUtils.getUtcCalendar());
}
@@ -273,7 +273,7 @@ public abstract class AbstractJdbcToArrowTest {
*/
public static VectorSchemaRoot sqlToArrow(ResultSet resultSet,
BufferAllocator allocator)
throws SQLException, IOException {
- Preconditions.checkNotNull(allocator, "Memory Allocator object can not be
null");
+ Preconditions.checkNotNull(allocator, "Memory Allocator object cannot be
null");
JdbcToArrowConfig config = new JdbcToArrowConfigBuilder(allocator,
JdbcToArrowUtils.getUtcCalendar())
.setArraySubTypeByColumnNameMap(ARRAY_SUB_TYPE_BY_COLUMN_NAME_MAP)
@@ -292,7 +292,7 @@ public abstract class AbstractJdbcToArrowTest {
* @throws SQLException on error
*/
public static VectorSchemaRoot sqlToArrow(ResultSet resultSet, Calendar
calendar) throws SQLException, IOException {
- Preconditions.checkNotNull(resultSet, "JDBC ResultSet object can not be
null");
+ Preconditions.checkNotNull(resultSet, "JDBC ResultSet object cannot be
null");
JdbcToArrowConfig config = new JdbcToArrowConfigBuilder(new
RootAllocator(Integer.MAX_VALUE), calendar)
.setArraySubTypeByColumnNameMap(ARRAY_SUB_TYPE_BY_COLUMN_NAME_MAP)
@@ -316,7 +316,7 @@ public abstract class AbstractJdbcToArrowTest {
BufferAllocator allocator,
Calendar calendar)
throws SQLException, IOException {
- Preconditions.checkNotNull(allocator, "Memory Allocator object can not be
null");
+ Preconditions.checkNotNull(allocator, "Memory Allocator object cannot be
null");
JdbcToArrowConfig config = new JdbcToArrowConfigBuilder(allocator,
calendar)
.setArraySubTypeByColumnNameMap(ARRAY_SUB_TYPE_BY_COLUMN_NAME_MAP)
@@ -336,7 +336,7 @@ public abstract class AbstractJdbcToArrowTest {
*/
public static VectorSchemaRoot sqlToArrow(ResultSet resultSet,
JdbcToArrowConfig config)
throws SQLException, IOException {
- Preconditions.checkNotNull(resultSet, "JDBC ResultSet object can not be
null");
+ Preconditions.checkNotNull(resultSet, "JDBC ResultSet object cannot be
null");
Preconditions.checkNotNull(config, "The configuration cannot be null");
VectorSchemaRoot root = VectorSchemaRoot.create(
diff --git
a/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/UnreliableMetaDataTest.java
b/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/UnreliableMetaDataTest.java
index 90554578d1..3eb886faab 100644
---
a/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/UnreliableMetaDataTest.java
+++
b/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/UnreliableMetaDataTest.java
@@ -151,7 +151,7 @@ public class UnreliableMetaDataTest {
assertThrows(RuntimeException.class, iter::next,
"This is expected to fail due to inconsistent BigDecimal scales,
while strict matching is enabled.");
}
- // Reuse same ResultSet, with RoundingMode.UNNECESSARY set to coerce
BigDecmial scale as needed:
+ // Reuse same ResultSet, with RoundingMode.UNNECESSARY set to coerce
BigDecimal scale as needed:
config = new JdbcToArrowConfigBuilder(
allocator, JdbcToArrowUtils.getUtcCalendar(), /* include metadata */
false)
.setReuseVectorSchemaRoot(reuseVectorSchemaRoot)
diff --git
a/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/h2/JdbcAliasToArrowTest.java
b/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/h2/JdbcAliasToArrowTest.java
index a6e6b22fcb..d9acfe88f4 100644
---
a/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/h2/JdbcAliasToArrowTest.java
+++
b/java/adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/h2/JdbcAliasToArrowTest.java
@@ -63,7 +63,7 @@ public class JdbcAliasToArrowTest {
/**
* Test h2 database query with alias for column name and column label.
- * To vetify reading field alias from an H2 database works as expected.
+ * To verify reading field alias from an H2 database works as expected.
* If this test fails, something is either wrong with the setup,
* or the H2 SQL behavior changed.
*/
diff --git a/java/c/src/main/java/org/apache/arrow/c/Data.java
b/java/c/src/main/java/org/apache/arrow/c/Data.java
index 6cb0c0ac40..a92853b350 100644
--- a/java/c/src/main/java/org/apache/arrow/c/Data.java
+++ b/java/c/src/main/java/org/apache/arrow/c/Data.java
@@ -222,7 +222,7 @@ public final class Data {
/**
* Export a reader as an ArrowArrayStream using the C Stream Interface.
- * @param allocator Buffer allocator for allocating C data inteface fields
+ * @param allocator Buffer allocator for allocating C data interface fields
* @param reader Reader to export
* @param out C struct to export the stream
*/
diff --git a/java/c/src/main/java/org/apache/arrow/c/NativeUtil.java
b/java/c/src/main/java/org/apache/arrow/c/NativeUtil.java
index b152ea4e7c..ba65fd80c4 100644
--- a/java/c/src/main/java/org/apache/arrow/c/NativeUtil.java
+++ b/java/c/src/main/java/org/apache/arrow/c/NativeUtil.java
@@ -115,7 +115,7 @@ public final class NativeUtil {
* Get the address of a buffer or {@value #NULL} if the input buffer is null.
*
* @param buf Buffer to get the address of
- * @return Memory addresss or {@value #NULL}
+ * @return Memory address or {@value #NULL}
*/
public static long addressOrNull(ArrowBuf buf) {
if (buf == null) {
@@ -129,7 +129,7 @@ public final class NativeUtil {
* struct is null.
*
* @param struct C Data Interface struct to get the address of
- * @return Memory addresss or {@value #NULL}
+ * @return Memory address or {@value #NULL}
*/
public static long addressOrNull(BaseStruct struct) {
if (struct == null) {
diff --git
a/java/c/src/main/java/org/apache/arrow/vector/StructVectorLoader.java
b/java/c/src/main/java/org/apache/arrow/vector/StructVectorLoader.java
index 10e3570177..4a62be7851 100644
--- a/java/c/src/main/java/org/apache/arrow/vector/StructVectorLoader.java
+++ b/java/c/src/main/java/org/apache/arrow/vector/StructVectorLoader.java
@@ -101,7 +101,7 @@ public class StructVectorLoader {
private void loadBuffers(FieldVector vector, Field field, Iterator<ArrowBuf>
buffers, Iterator<ArrowFieldNode> nodes,
CompressionCodec codec) {
- checkArgument(nodes.hasNext(), "no more field nodes for for field %s and
vector %s", field, vector);
+ checkArgument(nodes.hasNext(), "no more field nodes for field %s and
vector %s", field, vector);
ArrowFieldNode fieldNode = nodes.next();
int bufferLayoutCount = TypeLayout.getTypeBufferCount(field.getType());
List<ArrowBuf> ownBuffers = new ArrayList<>(bufferLayoutCount);
diff --git a/java/c/src/test/java/org/apache/arrow/c/DictionaryTest.java
b/java/c/src/test/java/org/apache/arrow/c/DictionaryTest.java
index 9dcb262af4..d892781756 100644
--- a/java/c/src/test/java/org/apache/arrow/c/DictionaryTest.java
+++ b/java/c/src/test/java/org/apache/arrow/c/DictionaryTest.java
@@ -128,7 +128,7 @@ public class DictionaryTest {
ArrowSchema consumerArrowSchema = ArrowSchema.allocateNew(allocator)) {
// Load first batch
reader.loadNextBatch();
- // Producer fills consumer schema stucture
+ // Producer fills consumer schema structure
Data.exportSchema(allocator, reader.getVectorSchemaRoot().getSchema(),
reader, consumerArrowSchema);
// Consumer loads it as an empty vector schema root
try (CDataDictionaryProvider consumerDictionaryProvider = new
CDataDictionaryProvider();
diff --git
a/java/compression/src/test/java/org/apache/arrow/compression/TestCompressionCodec.java
b/java/compression/src/test/java/org/apache/arrow/compression/TestCompressionCodec.java
index 7db00cfde4..403130edba 100644
---
a/java/compression/src/test/java/org/apache/arrow/compression/TestCompressionCodec.java
+++
b/java/compression/src/test/java/org/apache/arrow/compression/TestCompressionCodec.java
@@ -317,7 +317,7 @@ class TestCompressionCodec {
try (final VectorSchemaRoot root = VectorSchemaRoot.create(schema,
allocator)) {
final IntVector ints = (IntVector) root.getVector(0);
final VarCharVector strings = (VarCharVector) root.getVector(1);
- // Doesn't get compresed
+ // Doesn't get compressed
ints.setSafe(0, 0x4a3e);
ints.setSafe(1, 0x8aba);
ints.setSafe(2, 0x4362);
diff --git a/java/dataset/src/main/cpp/jni_util.cc
b/java/dataset/src/main/cpp/jni_util.cc
index f2f6871973..f1b5a7f7c6 100644
--- a/java/dataset/src/main/cpp/jni_util.cc
+++ b/java/dataset/src/main/cpp/jni_util.cc
@@ -192,9 +192,9 @@ std::string Describe(JNIEnv* env, jthrowable t) {
}
bool IsErrorInstanceOf(JNIEnv* env, jthrowable t, std::string class_name) {
- jclass jclass = env->FindClass(class_name.c_str());
- DCHECK_NE(jclass, nullptr) << "Could not find Java class " << class_name;
- return env->IsInstanceOf(t, jclass);
+ jclass java_class = env->FindClass(class_name.c_str());
+ DCHECK_NE(java_class, nullptr) << "Could not find Java class " << class_name;
+ return env->IsInstanceOf(t, java_class);
}
arrow::StatusCode MapJavaError(JNIEnv* env, jthrowable t) {
diff --git a/java/dataset/src/main/cpp/jni_wrapper.cc
b/java/dataset/src/main/cpp/jni_wrapper.cc
index 49e0f17209..d2d976677b 100644
--- a/java/dataset/src/main/cpp/jni_wrapper.cc
+++ b/java/dataset/src/main/cpp/jni_wrapper.cc
@@ -282,7 +282,7 @@ std::unordered_map<std::string,
std::shared_ptr<arrow::Table>> LoadNamedTables(J
std::unordered_map<std::string, std::shared_ptr<arrow::Table>>
map_table_to_record_batch_reader;
int length = env->GetArrayLength(str_array);
if (length % 2 != 0) {
- JniThrow("Can not map odd number of array elements to key/value pairs");
+ JniThrow("Cannot map odd number of array elements to key/value pairs");
}
std::shared_ptr<arrow::Table> output_table;
for (int pos = 0; pos < length; pos++) {
@@ -399,7 +399,7 @@ JNIEXPORT jlong JNICALL
Java_org_apache_arrow_dataset_jni_NativeMemoryPool_bytes
JNI_METHOD_START
arrow::MemoryPool* pool =
reinterpret_cast<arrow::MemoryPool*>(memory_pool_id);
if (pool == nullptr) {
- JniThrow("Memory pool instance not found. It may not exist nor has been
closed");
+ JniThrow("Memory pool instance not found. It may not exist or have been
closed");
}
return pool->bytes_allocated();
JNI_METHOD_END(-1L)
diff --git
a/java/dataset/src/main/java/org/apache/arrow/dataset/jni/JniWrapper.java
b/java/dataset/src/main/java/org/apache/arrow/dataset/jni/JniWrapper.java
index a7df5be42f..637a3e8f22 100644
--- a/java/dataset/src/main/java/org/apache/arrow/dataset/jni/JniWrapper.java
+++ b/java/dataset/src/main/java/org/apache/arrow/dataset/jni/JniWrapper.java
@@ -116,7 +116,7 @@ public class JniWrapper {
public native void releaseBuffer(long bufferId);
/**
- * Ensure the S3 APIs are shutdown, but only if not already done. If the S3
APIs are unintialized,
+ * Ensure the S3 APIs are shutdown, but only if not already done. If the S3
APIs are uninitialized,
* then this is a noop.
*/
public native void ensureS3Finalized();
diff --git
a/java/dataset/src/main/java/org/apache/arrow/dataset/substrait/JniWrapper.java
b/java/dataset/src/main/java/org/apache/arrow/dataset/substrait/JniWrapper.java
index 236d1d5616..5cb68f8514 100644
---
a/java/dataset/src/main/java/org/apache/arrow/dataset/substrait/JniWrapper.java
+++
b/java/dataset/src/main/java/org/apache/arrow/dataset/substrait/JniWrapper.java
@@ -25,7 +25,7 @@ import org.apache.arrow.dataset.jni.JniLoader;
* Class that contains Native methods to call Acero C++ Substrait API. It
internally depends on C++ function
* arrow::engine::ExecuteSerializedPlan. Currently supported input parameters
supported are:
* <pre>
- * - arrow::Buffer: Susbtrait Plan (JSON or Binary format).
+ * - arrow::Buffer: Substrait Plan (JSON or Binary format).
* - arrow::engine::ConversionOptions: Mapping for
arrow::engine::NamedTableProvider.
* </pre>
*/
diff --git
a/java/flight/flight-core/src/main/java/org/apache/arrow/flight/OutboundStreamListener.java
b/java/flight/flight-core/src/main/java/org/apache/arrow/flight/OutboundStreamListener.java
index 38a44d0e59..e80fb41c67 100644
---
a/java/flight/flight-core/src/main/java/org/apache/arrow/flight/OutboundStreamListener.java
+++
b/java/flight/flight-core/src/main/java/org/apache/arrow/flight/OutboundStreamListener.java
@@ -106,7 +106,7 @@ public interface OutboundStreamListener {
void completed();
/**
- * Toggle whether to ues the zero-copy write optimization.
+ * Toggle whether to use the zero-copy write optimization.
*
* <p>By default or when disabled, Arrow may copy data into a buffer for the
underlying implementation to
* send. When enabled, Arrow will instead try to directly enqueue the Arrow
buffer for sending. Not all
diff --git
a/java/flight/flight-core/src/main/java/org/apache/arrow/flight/auth2/ClientHandshakeWrapper.java
b/java/flight/flight-core/src/main/java/org/apache/arrow/flight/auth2/ClientHandshakeWrapper.java
index 16a5142509..c84739d2e3 100644
---
a/java/flight/flight-core/src/main/java/org/apache/arrow/flight/auth2/ClientHandshakeWrapper.java
+++
b/java/flight/flight-core/src/main/java/org/apache/arrow/flight/auth2/ClientHandshakeWrapper.java
@@ -61,7 +61,7 @@ public class ClientHandshakeWrapper {
throw wrappedException;
}
} catch (StatusRuntimeException sre) {
- logger.error("Failed with SREe", sre);
+ logger.error("Failed with SRE", sre);
throw StatusUtils.fromGrpcRuntimeException(sre);
} catch (Throwable ex) {
logger.error("Failed with unknown", ex);
diff --git
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/ArrowDatabaseMetadata.java
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/ArrowDatabaseMetadata.java
index 3487e58a64..d68b8070e2 100644
---
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/ArrowDatabaseMetadata.java
+++
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/ArrowDatabaseMetadata.java
@@ -1048,8 +1048,8 @@ public class ArrowDatabaseMetadata extends
AvaticaDatabaseMetaData {
SqlTypes.getSqlTypeNameFromArrowType(fieldType).getBytes(CHARSET);
typeNameVector.setSafe(insertIndex, typeName);
- // We're not setting COLUMN_SIZE for ROWID SQL Types, as there's no such
Arrow type.
- // We're not setting COLUMN_SIZE nor DECIMAL_DIGITS for Float/Double as
their precision and scale are variable.
+ // We aren't setting COLUMN_SIZE for ROWID SQL Types, as there's no such
Arrow type.
+ // We aren't setting COLUMN_SIZE nor DECIMAL_DIGITS for Float/Double as
their precision and scale are variable.
if (fieldType instanceof ArrowType.Decimal) {
numPrecRadixVector.setSafe(insertIndex, BASE10_RADIX);
} else if (fieldType instanceof ArrowType.Int) {
@@ -1101,7 +1101,7 @@ public class ArrowDatabaseMetadata extends
AvaticaDatabaseMetaData {
}
static Integer getDecimalDigits(final ArrowType fieldType) {
- // We're not setting DECIMAL_DIGITS for Float/Double as their precision
and scale are variable.
+ // We aren't setting DECIMAL_DIGITS for Float/Double as their precision
and scale are variable.
if (fieldType instanceof ArrowType.Decimal) {
final ArrowType.Decimal thisDecimal = (ArrowType.Decimal) fieldType;
return thisDecimal.getScale();
@@ -1141,8 +1141,8 @@ public class ArrowDatabaseMetadata extends
AvaticaDatabaseMetaData {
}
static Integer getColumnSize(final ArrowType fieldType) {
- // We're not setting COLUMN_SIZE for ROWID SQL Types, as there's no such
Arrow type.
- // We're not setting COLUMN_SIZE nor DECIMAL_DIGITS for Float/Double as
their precision and scale are variable.
+ // We aren't setting COLUMN_SIZE for ROWID SQL Types, as there's no such
Arrow type.
+ // We aren't setting COLUMN_SIZE nor DECIMAL_DIGITS for Float/Double as
their precision and scale are variable.
if (fieldType instanceof ArrowType.Decimal) {
final ArrowType.Decimal thisDecimal = (ArrowType.Decimal) fieldType;
return thisDecimal.getPrecision();
diff --git
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/client/ArrowFlightSqlClientHandler.java
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/client/ArrowFlightSqlClientHandler.java
index 54fd17853c..234820bd41 100644
---
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/client/ArrowFlightSqlClientHandler.java
+++
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/client/ArrowFlightSqlClientHandler.java
@@ -469,8 +469,8 @@ public final class ArrowFlightSqlClientHandler implements
AutoCloseable {
@VisibleForTesting
boolean retainAuth = true;
- // These two middlewares are for internal use within build() and should
not be exposed by builder APIs.
- // Note that these middlewares may not necessarily be registered.
+ // These two middleware are for internal use within build() and should not
be exposed by builder APIs.
+ // Note that these middleware may not necessarily be registered.
@VisibleForTesting
ClientIncomingAuthHeaderMiddleware.Factory authFactory
= new ClientIncomingAuthHeaderMiddleware.Factory(new
ClientBearerHeaderHandler());
@@ -742,7 +742,7 @@ public final class ArrowFlightSqlClientHandler implements
AutoCloseable {
* @throws SQLException on error.
*/
public ArrowFlightSqlClientHandler build() throws SQLException {
- // Copy middlewares so that the build method doesn't change the state of
the builder fields itself.
+ // Copy middleware so that the build method doesn't change the state of
the builder fields itself.
Set<FlightClientMiddleware.Factory> buildTimeMiddlewareFactories = new
HashSet<>(this.middlewareFactories);
FlightClient client = null;
boolean isUsingUserPasswordAuth = username != null && token == null;
diff --git
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/AvaticaParameterBinder.java
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/AvaticaParameterBinder.java
index 5fa3ba38f2..b2bd8e745e 100644
---
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/AvaticaParameterBinder.java
+++
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/AvaticaParameterBinder.java
@@ -94,7 +94,7 @@ public class AvaticaParameterBinder {
}
/**
- * Bind a TypedValue to the given index on the FieldVctor.
+ * Bind a TypedValue to the given index on the FieldVector.
*
* @param vector FieldVector to bind to.
* @param typedValue TypedValue to bind to the vector.
diff --git
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/VectorSchemaRootTransformer.java
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/VectorSchemaRootTransformer.java
index 3bab918c83..52a1d7db79 100644
---
a/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/VectorSchemaRootTransformer.java
+++
b/java/flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/utils/VectorSchemaRootTransformer.java
@@ -74,7 +74,7 @@ public interface VectorSchemaRootTransformer {
final ArrowType transformedType =
transformedVector.getField().getType();
if (!originalType.equals(transformedType)) {
throw new IllegalArgumentException(String.format(
- "Can not transfer vector with field type %s to %s",
originalType, transformedType));
+ "Cannot transfer vector with field type %s to %s", originalType,
transformedType));
}
if (originalVector instanceof BaseVariableWidthVector) {
@@ -85,7 +85,7 @@ public interface VectorSchemaRootTransformer {
((BaseFixedWidthVector) transformedVector));
} else {
throw new IllegalStateException(String.format(
- "Can not transfer vector of type %s",
originalVector.getClass()));
+ "Cannot transfer vector of type %s", originalVector.getClass()));
}
});
diff --git
a/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/ArrowFlightJdbcDriverTest.java
b/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/ArrowFlightJdbcDriverTest.java
index 9b8fa96d23..784fd5b292 100644
---
a/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/ArrowFlightJdbcDriverTest.java
+++
b/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/ArrowFlightJdbcDriverTest.java
@@ -142,7 +142,7 @@ public class ArrowFlightJdbcDriverTest {
driver.connect("jdbc:arrow-flight://" +
dataSource.getConfig().getHost() + ":" +
dataSource.getConfig().getPort() + "?" +
- "UseEncryptiOn=false",
+ "UseEncryptIon=false",
dataSource.getProperties(dataSource.getConfig().getUser(),
dataSource.getConfig().getPassword()))) {
assertTrue(connection.isValid(300));
}
@@ -150,7 +150,7 @@ public class ArrowFlightJdbcDriverTest {
driver.connect("jdbc:arrow-flight-sql://" +
dataSource.getConfig().getHost() + ":" +
dataSource.getConfig().getPort() + "?" +
- "UseEncryptiOn=false",
+ "UseEncryptIon=false",
dataSource.getProperties(dataSource.getConfig().getUser(),
dataSource.getConfig().getPassword()))) {
assertTrue(connection.isValid(300));
}
@@ -162,7 +162,7 @@ public class ArrowFlightJdbcDriverTest {
final Driver driver = new ArrowFlightJdbcDriver();
Properties properties =
dataSource.getProperties(dataSource.getConfig().getUser(),
dataSource.getConfig().getPassword());
- properties.put("UseEncryptiOn", "false");
+ properties.put("UseEncryptIon", "false");
try (Connection connection =
driver.connect("jdbc:arrow-flight://" +
diff --git
a/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/utils/MockFlightSqlProducer.java
b/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/utils/MockFlightSqlProducer.java
index f36956f193..c165bfb7ce 100644
---
a/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/utils/MockFlightSqlProducer.java
+++
b/java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/utils/MockFlightSqlProducer.java
@@ -195,7 +195,7 @@ public final class MockFlightSqlProducer implements
FlightSqlProducer {
final BiConsumer<FlightStream,
StreamListener<PutResult>> resultsProvider) {
Preconditions.checkState(
updateResultProviders.putIfAbsent(sqlCommand, resultsProvider) == null,
- format("Attempted to overwrite pre-existing query: <%s>.",
sqlCommand));
+ format("Attempted to overwrite preexisting query: <%s>.", sqlCommand));
}
/** Registers parameters expected to be provided with a prepared statement.
*/
diff --git
a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlColumnMetadata.java
b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlColumnMetadata.java
index bd52e4b495..186e8bc04e 100644
---
a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlColumnMetadata.java
+++
b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlColumnMetadata.java
@@ -145,8 +145,8 @@ public class FlightSqlColumnMetadata {
}
/**
- * Returns if the column is case sensitive.
- * @return True if the column is case sensitive, false otherwise.
+ * Returns if the column is case-sensitive.
+ * @return True if the column is case-sensitive, false otherwise.
*/
public Boolean isCaseSensitive() {
String value = metadataMap.get(IS_CASE_SENSITIVE);
@@ -267,8 +267,8 @@ public class FlightSqlColumnMetadata {
}
/**
- * Sets if the column is case sensitive.
- * @param isCaseSensitive If the column is case sensitive.
+ * Sets if the column is case-sensitive.
+ * @param isCaseSensitive If the column is case-sensitive.
* @return This builder.
*/
public Builder isCaseSensitive(boolean isCaseSensitive) {
diff --git
a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/util/TableRef.java
b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/util/TableRef.java
index 315f17ee91..b3751cab90 100644
---
a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/util/TableRef.java
+++
b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/util/TableRef.java
@@ -66,7 +66,7 @@ public class TableRef {
}
/**
- * Retreives the table from the object.
+ * Retrieves the table from the object.
* @return the table.
*/
public String getTable() {
diff --git
a/java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/JniLoader.java
b/java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/JniLoader.java
index 5158d52f8c..2528989f37 100644
---
a/java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/JniLoader.java
+++
b/java/gandiva/src/main/java/org/apache/arrow/gandiva/evaluator/JniLoader.java
@@ -158,10 +158,10 @@ class JniLoader {
synchronized (ConfigurationBuilder.class) {
if (defaultConfiguration == 0L) {
JniLoader.getInstance(); // setup
- ConfigurationBuilder.ConfigOptions defaultConfigOptons =
ConfigurationBuilder.ConfigOptions.getDefault();
+ ConfigurationBuilder.ConfigOptions defaultConfigOptions =
ConfigurationBuilder.ConfigOptions.getDefault();
defaultConfiguration = new ConfigurationBuilder()
- .buildConfigInstance(defaultConfigOptons);
- configurationMap.put(defaultConfigOptons, defaultConfiguration);
+ .buildConfigInstance(defaultConfigOptions);
+ configurationMap.put(defaultConfigOptions, defaultConfiguration);
}
}
}
diff --git
a/java/gandiva/src/main/java/org/apache/arrow/gandiva/expression/InNode.java
b/java/gandiva/src/main/java/org/apache/arrow/gandiva/expression/InNode.java
index 0f8de96286..bb1391b400 100644
--- a/java/gandiva/src/main/java/org/apache/arrow/gandiva/expression/InNode.java
+++ b/java/gandiva/src/main/java/org/apache/arrow/gandiva/expression/InNode.java
@@ -64,7 +64,7 @@ public class InNode implements TreeNode {
*
* @param node Node with the 'IN' clause.
* @param intValues Int values to build the IN node.
- * @retur InNode referring to tree node.
+ * @return InNode referring to tree node.
*/
public static InNode makeIntInExpr(TreeNode node, Set<Integer> intValues) {
return new InNode(intValues,
@@ -77,7 +77,7 @@ public class InNode implements TreeNode {
*
* @param node Node with the 'IN' clause.
* @param longValues Long values to build the IN node.
- * @retur InNode referring to tree node.
+ * @return InNode referring to tree node.
*/
public static InNode makeLongInExpr(TreeNode node, Set<Long> longValues) {
return new InNode(null, longValues,
@@ -90,7 +90,7 @@ public class InNode implements TreeNode {
*
* @param node Node with the 'IN' clause.
* @param floatValues Float values to build the IN node.
- * @retur InNode referring to tree node.
+ * @return InNode referring to tree node.
*/
public static InNode makeFloatInExpr(TreeNode node, Set<Float> floatValues) {
return new InNode(null, null, null, null, null, null,
@@ -102,7 +102,7 @@ public class InNode implements TreeNode {
*
* @param node Node with the 'IN' clause.
* @param doubleValues Double values to build the IN node.
- * @retur InNode referring to tree node.
+ * @return InNode referring to tree node.
*/
public static InNode makeDoubleInExpr(TreeNode node, Set<Double>
doubleValues) {
return new InNode(null, null, null, null, null,
diff --git
a/java/memory/memory-core/src/main/java/org/apache/arrow/memory/AllocationReservation.java
b/java/memory/memory-core/src/main/java/org/apache/arrow/memory/AllocationReservation.java
index 4331eb20ca..c672dc48d7 100644
---
a/java/memory/memory-core/src/main/java/org/apache/arrow/memory/AllocationReservation.java
+++
b/java/memory/memory-core/src/main/java/org/apache/arrow/memory/AllocationReservation.java
@@ -59,7 +59,7 @@ public interface AllocationReservation extends AutoCloseable {
* requested is available, if the allocation cannot be made contiguously.</p>
*
* @return the buffer, or null, if the request cannot be satisfied
- * @throws IllegalStateException if called called more than once
+ * @throws IllegalStateException if called more than once
*/
ArrowBuf allocateBuffer();
diff --git
a/java/memory/memory-core/src/main/java/org/apache/arrow/memory/ArrowBuf.java
b/java/memory/memory-core/src/main/java/org/apache/arrow/memory/ArrowBuf.java
index 5b322b4ff5..2c2e93b2d7 100644
---
a/java/memory/memory-core/src/main/java/org/apache/arrow/memory/ArrowBuf.java
+++
b/java/memory/memory-core/src/main/java/org/apache/arrow/memory/ArrowBuf.java
@@ -1210,7 +1210,7 @@ public final class ArrowBuf implements AutoCloseable {
}
/**
- * Returns <code>this</code> if size is less then {@link #capacity()},
otherwise
+ * Returns <code>this</code> if size is less than {@link #capacity()},
otherwise
* delegates to {@link BufferManager#replace(ArrowBuf, long)} to get a new
buffer.
*/
public ArrowBuf reallocIfNeeded(final long size) {
diff --git a/java/vector/src/main/codegen/templates/BaseWriter.java
b/java/vector/src/main/codegen/templates/BaseWriter.java
index 3b35d22692..35df256b32 100644
--- a/java/vector/src/main/codegen/templates/BaseWriter.java
+++ b/java/vector/src/main/codegen/templates/BaseWriter.java
@@ -117,7 +117,11 @@ public interface BaseWriter extends AutoCloseable,
Positionable {
void start();
void end();
StructOrListWriter struct(String name);
+ /**
+ * @deprecated use {@link #listOfStruct()} instead.
+ */
StructOrListWriter listoftstruct(String name);
+ StructOrListWriter listOfStruct(String name);
StructOrListWriter list(String name);
boolean isStructWriter();
boolean isListWriter();
diff --git a/java/vector/src/main/codegen/templates/DenseUnionVector.java
b/java/vector/src/main/codegen/templates/DenseUnionVector.java
index de0cf84fd8..c23caf3bb5 100644
--- a/java/vector/src/main/codegen/templates/DenseUnionVector.java
+++ b/java/vector/src/main/codegen/templates/DenseUnionVector.java
@@ -662,7 +662,7 @@ public class DenseUnionVector extends
AbstractContainerVector implements FieldVe
ReferenceManager refManager = slicedBuffer.getReferenceManager();
to.typeBuffer = refManager.transferOwnership(slicedBuffer,
to.allocator).getTransferredBuffer();
- // transfer offset byffer
+ // transfer offset buffer
while (to.offsetBuffer.capacity() < (long) length * OFFSET_WIDTH) {
to.reallocOffsetBuffer();
}
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/BaseFixedWidthVector.java
b/java/vector/src/main/java/org/apache/arrow/vector/BaseFixedWidthVector.java
index d09664e6d3..9022946011 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/BaseFixedWidthVector.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/BaseFixedWidthVector.java
@@ -478,7 +478,7 @@ public abstract class BaseFixedWidthVector extends
BaseValueVector
@Override
public void initializeChildrenFromFields(List<Field> children) {
if (!children.isEmpty()) {
- throw new IllegalArgumentException("primitive type vector can not have
children");
+ throw new IllegalArgumentException("primitive type vector cannot have
children");
}
}
@@ -608,7 +608,7 @@ public abstract class BaseFixedWidthVector extends
BaseValueVector
public abstract TransferPair getTransferPair(Field field, BufferAllocator
allocator);
/**
- * Transfer this vector'data to another vector. The memory associated
+ * Transfer this vector's data to another vector. The memory associated
* with this vector is transferred to the allocator of target vector
* for accounting and management purposes.
* @param target destination vector for transfer
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/BaseLargeVariableWidthVector.java
b/java/vector/src/main/java/org/apache/arrow/vector/BaseLargeVariableWidthVector.java
index fcac28bd08..a77278138f 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/BaseLargeVariableWidthVector.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/BaseLargeVariableWidthVector.java
@@ -276,7 +276,7 @@ public abstract class BaseLargeVariableWidthVector extends
BaseValueVector
@Override
public void initializeChildrenFromFields(List<Field> children) {
if (!children.isEmpty()) {
- throw new IllegalArgumentException("primitive type vector can not have
children");
+ throw new IllegalArgumentException("primitive type vector cannot have
children");
}
}
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/BaseVariableWidthVector.java
b/java/vector/src/main/java/org/apache/arrow/vector/BaseVariableWidthVector.java
index a0a5e085a5..46bc9815f0 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/BaseVariableWidthVector.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/BaseVariableWidthVector.java
@@ -295,7 +295,7 @@ public abstract class BaseVariableWidthVector extends
BaseValueVector
@Override
public void initializeChildrenFromFields(List<Field> children) {
if (!children.isEmpty()) {
- throw new IllegalArgumentException("primitive type vector can not have
children");
+ throw new IllegalArgumentException("primitive type vector cannot have
children");
}
}
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/Decimal256Vector.java
b/java/vector/src/main/java/org/apache/arrow/vector/Decimal256Vector.java
index 79a9badc39..fe650c7d28 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/Decimal256Vector.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/Decimal256Vector.java
@@ -212,7 +212,7 @@ public final class Decimal256Vector extends
BaseFixedWidthVector {
* ArrowBuf of decimal vector.
*
* <p>This method takes care of adding the necessary padding if the length
- * of byte array is less then 32 (length of decimal type).
+ * of byte array is less than 32 (length of decimal type).
*
* @param index position of element
* @param value array of bytes containing decimal in big endian byte order.
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/DecimalVector.java
b/java/vector/src/main/java/org/apache/arrow/vector/DecimalVector.java
index d1a3bfc3af..7c3662c867 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/DecimalVector.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/DecimalVector.java
@@ -159,7 +159,7 @@ public final class DecimalVector extends
BaseFixedWidthVector {
}
/**
- * Same as {@link #getObect(int)} but does not check for null.
+ * Same as {@link #getObject(int)} but does not check for null.
*
* @param index position of element
* @return element at given index
@@ -211,7 +211,7 @@ public final class DecimalVector extends
BaseFixedWidthVector {
* ArrowBuf of decimal vector.
*
* <p>This method takes care of adding the necessary padding if the length
- * of byte array is less then 16 (length of decimal type).
+ * of byte array is less than 16 (length of decimal type).
*
* @param index position of element
* @param value array of bytes containing decimal in big endian byte order.
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/ExtensionTypeVector.java
b/java/vector/src/main/java/org/apache/arrow/vector/ExtensionTypeVector.java
index a70efe61bc..3a35a44403 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ExtensionTypeVector.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ExtensionTypeVector.java
@@ -50,7 +50,7 @@ public abstract class ExtensionTypeVector<T extends
ValueVector & FieldVector> e
*/
public ExtensionTypeVector(String name, BufferAllocator allocator, T
underlyingVector) {
super(allocator);
- Preconditions.checkNotNull(underlyingVector, "underlyingVector can not be
null.");
+ Preconditions.checkNotNull(underlyingVector, "underlyingVector cannot be
null.");
this.name = name;
this.underlyingVector = underlyingVector;
}
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/IntervalMonthDayNanoVector.java
b/java/vector/src/main/java/org/apache/arrow/vector/IntervalMonthDayNanoVector.java
index 73bbc0a2c1..fc0aa9d27b 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/IntervalMonthDayNanoVector.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/IntervalMonthDayNanoVector.java
@@ -39,7 +39,7 @@ import org.apache.arrow.vector.util.TransferPair;
* A validity buffer (bit vector) is maintained to track which elements in the
* vector are null.
*
- * Month, day and nanoseconds are indepndent from one another and there
+ * Month, day and nanoseconds are independent from one another and there
* is no specific limits imposed on their values.
*/
public final class IntervalMonthDayNanoVector extends BaseFixedWidthVector {
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/VectorLoader.java
b/java/vector/src/main/java/org/apache/arrow/vector/VectorLoader.java
index ed5f3aef17..510cef24c7 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/VectorLoader.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/VectorLoader.java
@@ -96,7 +96,7 @@ public class VectorLoader {
Iterator<ArrowBuf> buffers,
Iterator<ArrowFieldNode> nodes,
CompressionCodec codec) {
- checkArgument(nodes.hasNext(), "no more field nodes for for field %s and
vector %s", field, vector);
+ checkArgument(nodes.hasNext(), "no more field nodes for field %s and
vector %s", field, vector);
ArrowFieldNode fieldNode = nodes.next();
int bufferLayoutCount = TypeLayout.getTypeBufferCount(field.getType());
List<ArrowBuf> ownBuffers = new ArrayList<>(bufferLayoutCount);
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/complex/StructVector.java
b/java/vector/src/main/java/org/apache/arrow/vector/complex/StructVector.java
index d0304a6fd2..27db157480 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/complex/StructVector.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/complex/StructVector.java
@@ -100,7 +100,7 @@ public class StructVector extends NonNullableStructVector
implements FieldVector
* @param fieldType The type of this list.
* @param callBack A schema change callback.
* @param conflictPolicy policy to determine how duplicate names are handled.
- * @param allowConflictPolicyChanges wether duplicate names are allowed at
all.
+ * @param allowConflictPolicyChanges whether duplicate names are allowed at
all.
*/
public StructVector(String name,
BufferAllocator allocator,
@@ -139,7 +139,7 @@ public class StructVector extends NonNullableStructVector
implements FieldVector
* @param allocator The allocator to use to allocating/reallocating buffers.
* @param callBack A schema change callback.
* @param conflictPolicy policy to determine how duplicate names are handled.
- * @param allowConflictPolicyChanges wether duplicate names are allowed at
all.
+ * @param allowConflictPolicyChanges whether duplicate names are allowed at
all.
*/
public StructVector(Field field,
BufferAllocator allocator,
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/ComplexWriterImpl.java
b/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/ComplexWriterImpl.java
index 8d2694b6df..8dd5763990 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/ComplexWriterImpl.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/ComplexWriterImpl.java
@@ -49,7 +49,7 @@ public class ComplexWriterImpl extends AbstractFieldWriter
implements ComplexWri
* @param name The name of the writer (for tracking).
* @param container A container for the data field to be written.
* @param unionEnabled Unused.
- * @param caseSensitive Whether field names are case sensitive (if false
field names will be lowercase.
+ * @param caseSensitive Whether field names are case-sensitive (if false
field names will be lowercase.
*/
public ComplexWriterImpl(
String name,
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/NullableStructWriterFactory.java
b/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/NullableStructWriterFactory.java
index 458aa7b610..a305529b71 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/NullableStructWriterFactory.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/NullableStructWriterFactory.java
@@ -21,7 +21,7 @@ import org.apache.arrow.vector.complex.StructVector;
/**
* A factory for {@link NullableStructWriter} instances. The factory allows
for configuring if field
- * names should be considered case sensitive.
+ * names should be considered case-sensitive.
*/
public class NullableStructWriterFactory {
private final boolean caseSensitive;
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/StructOrListWriterImpl.java
b/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/StructOrListWriterImpl.java
index e9c0825dd3..5c4cd2af98 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/StructOrListWriterImpl.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/complex/impl/StructOrListWriterImpl.java
@@ -87,8 +87,19 @@ public class StructOrListWriterImpl implements
StructOrListWriter {
* Creates a new writer for a list of structs.
*
* @param name Unused.
+ *
+ * @deprecated use {@link #listOfStruct()} instead.
*/
public StructOrListWriter listoftstruct(final String name) {
+ return listOfStruct(name);
+ }
+
+ /**
+ * Creates a new writer for a list of structs.
+ *
+ * @param name Unused.
+ */
+ public StructOrListWriter listOfStruct(final String name) {
assert list != null;
return new StructOrListWriterImpl(list.struct());
}
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/util/DecimalUtility.java
b/java/vector/src/main/java/org/apache/arrow/vector/util/DecimalUtility.java
index a81169b8f7..0dfb61dcdf 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/util/DecimalUtility.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/util/DecimalUtility.java
@@ -94,7 +94,7 @@ public class DecimalUtility {
value.scale() + " != " + vectorScale);
}
if (value.precision() > vectorPrecision) {
- throw new UnsupportedOperationException("BigDecimal precision can not be
greater than that in the Arrow " +
+ throw new UnsupportedOperationException("BigDecimal precision cannot be
greater than that in the Arrow " +
"vector: " + value.precision() + " > " + vectorPrecision);
}
return true;
@@ -120,7 +120,7 @@ public class DecimalUtility {
decimalScale + " != " + vectorScale);
}
if (decimalPrecision > vectorPrecision) {
- throw new UnsupportedOperationException("BigDecimal precision can not be
greater than that in the Arrow " +
+ throw new UnsupportedOperationException("BigDecimal precision cannot be
greater than that in the Arrow " +
"vector: " + decimalPrecision + " > " + vectorPrecision);
}
return true;
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/util/VectorAppender.java
b/java/vector/src/main/java/org/apache/arrow/vector/util/VectorAppender.java
index c5de380f9c..068717c7ac 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/util/VectorAppender.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/util/VectorAppender.java
@@ -506,7 +506,7 @@ public class VectorAppender implements
VectorVisitor<ValueVector, Void> {
targetChildVector = targetDenseUnionVector.addVector(
(byte) i,
deltaChildVector.getField().createVector(targetDenseUnionVector.getAllocator()));
- // now we have both child vecors not null, we can append them.
+ // now we have both child vectors not null, we can append them.
VectorAppender childAppender = new VectorAppender(targetChildVector);
deltaChildVector.accept(childAppender, null);
} else if (targetChildVector != null && deltaChildVector == null) {
diff --git
a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorTypeVisitor.java
b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorTypeVisitor.java
index 08e3ccccfa..3d1c5a4f27 100644
---
a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorTypeVisitor.java
+++
b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorTypeVisitor.java
@@ -280,7 +280,7 @@ public class ValidateVectorTypeVisitor implements
VectorVisitor<Void, Void> {
validateOrThrow(arrowType.getByteWidth() > 0, "The byte width of a
FixedSizeBinaryVector %s is not positive.",
arrowType.getByteWidth());
validateOrThrow(arrowType.getByteWidth() == vector.getTypeWidth(),
- "Type width mismatch for FixedSizeBinaryVector. Vector type width
%s, arrow type type width %s.",
+ "Type width mismatch for FixedSizeBinaryVector. Vector type width
%s, arrow type width %s.",
vector.getTypeWidth(), arrowType.getByteWidth());
} else {
throw new IllegalArgumentException("Unknown type for fixed width vector
" + vector.getClass());
diff --git
a/java/vector/src/test/java/org/apache/arrow/vector/TestDecimal256Vector.java
b/java/vector/src/test/java/org/apache/arrow/vector/TestDecimal256Vector.java
index 51368cf6ae..b703959d2b 100644
---
a/java/vector/src/test/java/org/apache/arrow/vector/TestDecimal256Vector.java
+++
b/java/vector/src/test/java/org/apache/arrow/vector/TestDecimal256Vector.java
@@ -104,7 +104,7 @@ public class TestDecimal256Vector {
BigDecimal decimal = new BigDecimal(BigInteger.valueOf(12345), 2);
UnsupportedOperationException ue =
assertThrows(UnsupportedOperationException.class, () ->
decimalVector.setSafe(0, decimal));
- assertEquals("BigDecimal precision can not be greater than that in the
Arrow vector: 5 > 4", ue.getMessage());
+ assertEquals("BigDecimal precision cannot be greater than that in the
Arrow vector: 5 > 4", ue.getMessage());
}
}
}
diff --git
a/java/vector/src/test/java/org/apache/arrow/vector/TestDenseUnionVector.java
b/java/vector/src/test/java/org/apache/arrow/vector/TestDenseUnionVector.java
index 01becf0079..9cb1248161 100644
---
a/java/vector/src/test/java/org/apache/arrow/vector/TestDenseUnionVector.java
+++
b/java/vector/src/test/java/org/apache/arrow/vector/TestDenseUnionVector.java
@@ -610,9 +610,9 @@ public class TestDenseUnionVector {
assertEquals(8L, longVector.get(0));
assertEquals(12L, longVector.get(1));
- Float4Vector floagVector = (Float4Vector)
vector.getVectorByType(floatTypeId);
- assertEquals(1, floagVector.getValueCount());
- assertEquals(9.0f, floagVector.get(0), 0);
+ Float4Vector floatVector = (Float4Vector)
vector.getVectorByType(floatTypeId);
+ assertEquals(1, floatVector.getValueCount());
+ assertEquals(9.0f, floatVector.get(0), 0);
}
}
diff --git
a/java/vector/src/test/java/org/apache/arrow/vector/TestVectorReAlloc.java
b/java/vector/src/test/java/org/apache/arrow/vector/TestVectorReAlloc.java
index 18bb2c9573..7d5701ddb7 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestVectorReAlloc.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestVectorReAlloc.java
@@ -255,7 +255,7 @@ public class TestVectorReAlloc {
try (final VarCharVector vector = new VarCharVector("", allocator)) {
vector.allocateNew(count);
- // verify that the validity buffer and value buffer have capacity for
atleast 'count' elements.
+ // verify that the validity buffer and value buffer have capacity for at
least 'count' elements.
Assert.assertTrue(vector.getValidityBuffer().capacity() >=
DataSizeRoundingUtil.divideBy8Ceil(count));
Assert.assertTrue(vector.getOffsetBuffer().capacity() >= (count + 1) *
BaseVariableWidthVector.OFFSET_WIDTH);
}
@@ -268,7 +268,7 @@ public class TestVectorReAlloc {
try (final LargeVarCharVector vector = new LargeVarCharVector("",
allocator)) {
vector.allocateNew(count);
- // verify that the validity buffer and value buffer have capacity for
atleast 'count' elements.
+ // verify that the validity buffer and value buffer have capacity for at
least 'count' elements.
Assert.assertTrue(vector.getValidityBuffer().capacity() >=
DataSizeRoundingUtil.divideBy8Ceil(count));
Assert.assertTrue(vector.getOffsetBuffer().capacity() >= (count + 1) *
BaseLargeVariableWidthVector.OFFSET_WIDTH);
}
@@ -281,7 +281,7 @@ public class TestVectorReAlloc {
try (final VarCharVector vector = new VarCharVector("", allocator)) {
AllocationHelper.allocateNew(vector, count);
- // verify that the validity buffer and value buffer have capacity for
atleast 'count' elements.
+ // verify that the validity buffer and value buffer have capacity for at
least 'count' elements.
Assert.assertTrue(vector.getValidityBuffer().capacity() >=
DataSizeRoundingUtil.divideBy8Ceil(count));
Assert.assertTrue(vector.getOffsetBuffer().capacity() >= (count + 1) *
BaseVariableWidthVector.OFFSET_WIDTH);
}
@@ -294,7 +294,7 @@ public class TestVectorReAlloc {
try (final LargeVarCharVector vector = new LargeVarCharVector("",
allocator)) {
AllocationHelper.allocateNew(vector, count);
- // verify that the validity buffer and value buffer have capacity for
atleast 'count' elements.
+ // verify that the validity buffer and value buffer have capacity for at
least 'count' elements.
Assert.assertTrue(vector.getValidityBuffer().capacity() >=
DataSizeRoundingUtil.divideBy8Ceil(count));
Assert.assertTrue(vector.getOffsetBuffer().capacity() >= (count + 1) *
BaseLargeVariableWidthVector.OFFSET_WIDTH);
}
diff --git
a/java/vector/src/test/java/org/apache/arrow/vector/ipc/MessageSerializerTest.java
b/java/vector/src/test/java/org/apache/arrow/vector/ipc/MessageSerializerTest.java
index 11b8d4fadd..79a4b249a8 100644
---
a/java/vector/src/test/java/org/apache/arrow/vector/ipc/MessageSerializerTest.java
+++
b/java/vector/src/test/java/org/apache/arrow/vector/ipc/MessageSerializerTest.java
@@ -108,7 +108,7 @@ public class MessageSerializerTest {
// First message continuation, size, and 2 int values
assertEquals(MessageSerializer.IPC_CONTINUATION_TOKEN, result.getInt());
- // mesage length is represented in little endian
+ // message length is represented in little endian
result.order(ByteOrder.LITTLE_ENDIAN);
assertEquals(8, result.getInt());
result.order(ByteOrder.nativeOrder());
@@ -117,7 +117,7 @@ public class MessageSerializerTest {
// Second message continuation, size, 1 int value and 4 bytes padding
assertEquals(MessageSerializer.IPC_CONTINUATION_TOKEN, result.getInt());
- // mesage length is represented in little endian
+ // message length is represented in little endian
result.order(ByteOrder.LITTLE_ENDIAN);
assertEquals(8, result.getInt());
result.order(ByteOrder.nativeOrder());
diff --git
a/java/vector/src/test/java/org/apache/arrow/vector/types/pojo/TestExtensionType.java
b/java/vector/src/test/java/org/apache/arrow/vector/types/pojo/TestExtensionType.java
index 1b3d5eee35..084350410a 100644
---
a/java/vector/src/test/java/org/apache/arrow/vector/types/pojo/TestExtensionType.java
+++
b/java/vector/src/test/java/org/apache/arrow/vector/types/pojo/TestExtensionType.java
@@ -177,7 +177,7 @@ public class TestExtensionType {
vector.allocateNewSafe();
}
});
- assertTrue(e.getMessage().contains("underlyingVector can not be null."));
+ assertTrue(e.getMessage().contains("underlyingVector cannot be null."));
}
/**
