dataBuffers) throws IOException {
if (bufferType.equals(VARIADIC_DATA_BUFFERS)) {
Preconditions.checkNotNull(viewBuffer);
Preconditions.checkArgument(!dataBuffers.isEmpty());
@@ -560,8 +556,8 @@ private void writeValueToGenerator(
case VARCHAR:
{
Preconditions.checkNotNull(offsetBuffer);
- byte[] b = (BaseVariableWidthVector.get(buffer, offsetBuffer, index));
- generator.writeString(new String(b, "UTF-8"));
+ byte[] b = BaseVariableWidthVector.get(buffer, offsetBuffer, index);
+ generator.writeString(new String(b, StandardCharsets.UTF_8));
break;
}
case DECIMAL:
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/ipc/WriteChannel.java b/java/vector/src/main/java/org/apache/arrow/vector/ipc/WriteChannel.java
index eeb2eaf566d..fca6b13cd54 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ipc/WriteChannel.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ipc/WriteChannel.java
@@ -23,8 +23,6 @@
import org.apache.arrow.memory.ArrowBuf;
import org.apache.arrow.vector.ipc.message.FBSerializable;
import org.apache.arrow.vector.ipc.message.MessageSerializer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
/**
* Wrapper around a WritableByteChannel that maintains the position as well adding some common
@@ -37,7 +35,6 @@
* Please note that objects of this class are not thread-safe.
*/
public class WriteChannel implements AutoCloseable {
- private static final Logger LOGGER = LoggerFactory.getLogger(WriteChannel.class);
private static final byte[] ZERO_BYTES = new byte[8];
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBlock.java b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBlock.java
index 455229cc6dd..ff002794ed5 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBlock.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBlock.java
@@ -75,7 +75,7 @@ public boolean equals(Object obj) {
if (obj == null) {
return false;
}
- if (getClass() != obj.getClass()) {
+ if (!(obj instanceof ArrowBlock)) {
return false;
}
ArrowBlock other = (ArrowBlock) obj;
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBuffer.java b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBuffer.java
index cebddeb660e..1ec9888bd79 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBuffer.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBuffer.java
@@ -62,7 +62,7 @@ public boolean equals(Object obj) {
if (obj == null) {
return false;
}
- if (getClass() != obj.getClass()) {
+ if (!(obj instanceof ArrowBuffer)) {
return false;
}
ArrowBuffer other = (ArrowBuffer) obj;
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowDictionaryBatch.java b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowDictionaryBatch.java
index cee76433ea4..208092c9461 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowDictionaryBatch.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowDictionaryBatch.java
@@ -16,6 +16,7 @@
*/
package org.apache.arrow.vector.ipc.message;
+import com.google.errorprone.annotations.InlineMe;
import com.google.flatbuffers.FlatBufferBuilder;
import org.apache.arrow.flatbuf.DictionaryBatch;
import org.apache.arrow.flatbuf.MessageHeader;
@@ -31,6 +32,7 @@ public class ArrowDictionaryBatch implements ArrowMessage {
private final boolean isDelta;
@Deprecated
+ @InlineMe(replacement = "this(dictionaryId, dictionary, false)")
public ArrowDictionaryBatch(long dictionaryId, ArrowRecordBatch dictionary) {
this(dictionaryId, dictionary, false);
}
@@ -46,6 +48,7 @@ public boolean isDelta() {
return isDelta;
}
+ @Override
public byte getMessageType() {
return MessageHeader.DictionaryBatch;
}
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowFooter.java b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowFooter.java
index bb2b87113fa..27ef82a603b 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowFooter.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowFooter.java
@@ -190,7 +190,7 @@ public boolean equals(Object obj) {
if (obj == null) {
return false;
}
- if (getClass() != obj.getClass()) {
+ if (!(obj instanceof ArrowFooter)) {
return false;
}
ArrowFooter other = (ArrowFooter) obj;
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowRecordBatch.java b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowRecordBatch.java
index bc6bfa8c868..73b4c5313ff 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowRecordBatch.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowRecordBatch.java
@@ -182,6 +182,7 @@ public ArrowRecordBatch(
// this constructor is different from the public ones in that the reference manager's
// retain method is not called, so the first dummy parameter is used
// to distinguish this from the public constructor.
+ @SuppressWarnings("UnusedVariable")
private ArrowRecordBatch(
boolean dummy,
int length,
@@ -206,6 +207,7 @@ private ArrowRecordBatch(
this.buffersLayout = Collections.unmodifiableList(arrowBuffers);
}
+ @Override
public byte getMessageType() {
return org.apache.arrow.flatbuf.MessageHeader.RecordBatch;
}
@@ -261,9 +263,9 @@ public ArrowRecordBatch cloneWithTransfer(final BufferAllocator allocator) {
buffers.stream()
.map(
buf ->
- (buf.getReferenceManager()
- .transferOwnership(buf, allocator)
- .getTransferredBuffer())
+ buf.getReferenceManager()
+ .transferOwnership(buf, allocator)
+ .getTransferredBuffer()
.writerIndex(buf.writerIndex()))
.collect(Collectors.toList());
close();
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/MessageSerializer.java b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/MessageSerializer.java
index 36f6ea449b0..7ba72ed2bb5 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/MessageSerializer.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/MessageSerializer.java
@@ -18,6 +18,7 @@
import static org.apache.arrow.memory.util.LargeMemoryUtil.checkedCastToInt;
+import com.google.errorprone.annotations.InlineMe;
import com.google.flatbuffers.FlatBufferBuilder;
import java.io.IOException;
import java.nio.ByteBuffer;
@@ -63,7 +64,7 @@ public static int bytesToInt(byte[] bytes) {
return ((bytes[3] & 255) << 24)
+ ((bytes[2] & 255) << 16)
+ ((bytes[1] & 255) << 8)
- + ((bytes[0] & 255));
+ + (bytes[0] & 255);
}
/**
@@ -76,7 +77,7 @@ public static void intToBytes(int value, byte[] bytes) {
bytes[3] = (byte) (value >>> 24);
bytes[2] = (byte) (value >>> 16);
bytes[1] = (byte) (value >>> 8);
- bytes[0] = (byte) (value);
+ bytes[0] = (byte) value;
}
/**
@@ -93,7 +94,7 @@ public static void longToBytes(long value, byte[] bytes) {
bytes[3] = (byte) (value >>> 24);
bytes[2] = (byte) (value >>> 16);
bytes[1] = (byte) (value >>> 8);
- bytes[0] = (byte) (value);
+ bytes[0] = (byte) value;
}
public static int writeMessageBuffer(
@@ -166,6 +167,12 @@ public static long serialize(WriteChannel out, Schema schema, IpcOption option)
/** Returns the serialized flatbuffer bytes of the schema wrapped in a message table. */
@Deprecated
+ @InlineMe(
+ replacement = "MessageSerializer.serializeMetadata(schema, IpcOption.DEFAULT)",
+ imports = {
+ "org.apache.arrow.vector.ipc.message.IpcOption",
+ "org.apache.arrow.vector.ipc.message.MessageSerializer"
+ })
public static ByteBuffer serializeMetadata(Schema schema) {
return serializeMetadata(schema, IpcOption.DEFAULT);
}
@@ -314,6 +321,12 @@ public static long writeBatchBuffers(WriteChannel out, ArrowRecordBatch batch)
* org.apache.arrow.flatbuf.Message}.
*/
@Deprecated
+ @InlineMe(
+ replacement = "MessageSerializer.serializeMetadata(message, IpcOption.DEFAULT)",
+ imports = {
+ "org.apache.arrow.vector.ipc.message.IpcOption",
+ "org.apache.arrow.vector.ipc.message.MessageSerializer"
+ })
public static ByteBuffer serializeMetadata(ArrowMessage message) {
return serializeMetadata(message, IpcOption.DEFAULT);
}
@@ -655,6 +668,13 @@ public static ArrowMessage deserializeMessageBatch(ReadChannel in, BufferAllocat
}
@Deprecated
+ @InlineMe(
+ replacement =
+ "MessageSerializer.serializeMessage(builder, headerType, headerOffset, bodyLength, IpcOption.DEFAULT)",
+ imports = {
+ "org.apache.arrow.vector.ipc.message.IpcOption",
+ "org.apache.arrow.vector.ipc.message.MessageSerializer"
+ })
public static ByteBuffer serializeMessage(
FlatBufferBuilder builder, byte headerType, int headerOffset, long bodyLength) {
return serializeMessage(builder, headerType, headerOffset, bodyLength, IpcOption.DEFAULT);
@@ -695,6 +715,7 @@ public static ByteBuffer serializeMessage(
* valid Message was read, or null if end-of-stream
* @throws IOException on error
*/
+ @SuppressWarnings("UnusedVariable")
public static MessageMetadataResult readMessage(ReadChannel in) throws IOException {
// Read the message size. There is an i32 little endian prefix.
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/types/pojo/Schema.java b/java/vector/src/main/java/org/apache/arrow/vector/types/pojo/Schema.java
index 293f1499df2..7b2cc1859a3 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/types/pojo/Schema.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/types/pojo/Schema.java
@@ -28,6 +28,7 @@
import com.fasterxml.jackson.databind.ObjectReader;
import com.fasterxml.jackson.databind.ObjectWriter;
import com.fasterxml.jackson.databind.util.ByteBufferBackedInputStream;
+import com.google.errorprone.annotations.InlineMe;
import com.google.flatbuffers.FlatBufferBuilder;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
@@ -90,6 +91,9 @@ public static Schema fromJSON(String json) throws IOException {
* @return The deserialized schema.
*/
@Deprecated
+ @InlineMe(
+ replacement = "Schema.convertSchema(org.apache.arrow.flatbuf.Schema.getRootAsSchema(buffer))",
+ imports = "org.apache.arrow.vector.types.pojo.Schema")
public static Schema deserialize(ByteBuffer buffer) {
return convertSchema(org.apache.arrow.flatbuf.Schema.getRootAsSchema(buffer));
}
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 31b79fe53a4..0bd29526fd0 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
@@ -27,12 +27,12 @@
public class DecimalUtility {
private DecimalUtility() {}
- public static final byte[] zeroes =
+ private static final byte[] zeroes =
new byte[] {
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0
};
- public static final byte[] minus_one =
+ private static final byte[] minus_one =
new byte[] {
-1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
-1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1
@@ -172,11 +172,11 @@ public static void writeLongToArrowBuf(long value, ArrowBuf bytebuf, int index,
if (LITTLE_ENDIAN) {
MemoryUtil.putLong(addressOfValue, value);
for (int i = 1; i <= (byteWidth - 8) / 8; i++) {
- MemoryUtil.putLong(addressOfValue + Long.BYTES * i, padValue);
+ MemoryUtil.putLong(addressOfValue + Long.BYTES * ((long) i), padValue);
}
} else {
for (int i = 0; i < (byteWidth - 8) / 8; i++) {
- MemoryUtil.putLong(addressOfValue + Long.BYTES * i, padValue);
+ MemoryUtil.putLong(addressOfValue + Long.BYTES * ((long) i), padValue);
}
MemoryUtil.putLong(addressOfValue + Long.BYTES * (byteWidth - 8) / 8, value);
}
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/util/IntObjectHashMap.java b/java/vector/src/main/java/org/apache/arrow/vector/util/IntObjectHashMap.java
index b625f602caa..7b6a8a6d91b 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/util/IntObjectHashMap.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/util/IntObjectHashMap.java
@@ -412,8 +412,8 @@ private boolean removeAt(final int index) {
for (V value = values[i]; value != null; value = values[i = probeNext(i)]) {
int key = keys[i];
int bucket = hashIndex(key);
- if (i < bucket && (bucket <= nextFree || nextFree <= i)
- || bucket <= nextFree && nextFree <= i) {
+ if ((i < bucket && (bucket <= nextFree || nextFree <= i))
+ || (bucket <= nextFree && nextFree <= i)) {
// Move the displaced entry "back" to the first available position.
keys[nextFree] = key;
values[nextFree] = value;
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/util/Text.java b/java/vector/src/main/java/org/apache/arrow/vector/util/Text.java
index 35d810abbb6..4fd25186872 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/util/Text.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/util/Text.java
@@ -200,8 +200,12 @@ public int find(String what, int start) {
public void set(String string) {
try {
ByteBuffer bb = encode(string, true);
- bytes = bb.array();
- length = bb.limit();
+ byte[] bytes = new byte[bb.remaining()];
+ int originalPosition = bb.position();
+ bb.get(bytes);
+ bb.position(originalPosition); // Restores the buffer position
+ this.bytes = bytes;
+ this.length = bb.limit();
} catch (CharacterCodingException e) {
throw new RuntimeException("Should not have happened ", e);
}
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 e703571b374..f97310ac736 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
@@ -96,8 +96,8 @@ public ValueVector visit(BaseFixedWidthVector deltaVector, Void value) {
MemoryUtil.copyMemory(
deltaVector.getDataBuffer().memoryAddress(),
targetVector.getDataBuffer().memoryAddress()
- + deltaVector.getTypeWidth() * targetVector.getValueCount(),
- deltaVector.getTypeWidth() * deltaVector.getValueCount());
+ + (long) deltaVector.getTypeWidth() * targetVector.getValueCount(),
+ (long) deltaVector.getTypeWidth() * deltaVector.getValueCount());
}
targetVector.setValueCount(newValueCount);
return targetVector;
@@ -151,8 +151,8 @@ public ValueVector visit(BaseVariableWidthVector deltaVector, Void value) {
MemoryUtil.copyMemory(
deltaVector.getOffsetBuffer().memoryAddress() + BaseVariableWidthVector.OFFSET_WIDTH,
targetVector.getOffsetBuffer().memoryAddress()
- + (targetVector.getValueCount() + 1) * BaseVariableWidthVector.OFFSET_WIDTH,
- deltaVector.getValueCount() * BaseVariableWidthVector.OFFSET_WIDTH);
+ + (long) (targetVector.getValueCount() + 1) * BaseVariableWidthVector.OFFSET_WIDTH,
+ (long) deltaVector.getValueCount() * BaseVariableWidthVector.OFFSET_WIDTH);
// increase each offset from the second buffer
for (int i = 0; i < deltaVector.getValueCount(); i++) {
@@ -223,8 +223,8 @@ public ValueVector visit(BaseLargeVariableWidthVector deltaVector, Void value) {
MemoryUtil.copyMemory(
deltaVector.getOffsetBuffer().memoryAddress() + BaseLargeVariableWidthVector.OFFSET_WIDTH,
targetVector.getOffsetBuffer().memoryAddress()
- + (targetVector.getValueCount() + 1) * BaseLargeVariableWidthVector.OFFSET_WIDTH,
- deltaVector.getValueCount() * BaseLargeVariableWidthVector.OFFSET_WIDTH);
+ + (long) (targetVector.getValueCount() + 1) * BaseLargeVariableWidthVector.OFFSET_WIDTH,
+ (long) deltaVector.getValueCount() * BaseLargeVariableWidthVector.OFFSET_WIDTH);
// increase each offset from the second buffer
for (int i = 0; i < deltaVector.getValueCount(); i++) {
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateUtil.java b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateUtil.java
index 015ee265d14..b6490a84ab4 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateUtil.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateUtil.java
@@ -16,6 +16,8 @@
*/
package org.apache.arrow.vector.validate;
+import com.google.errorprone.annotations.FormatMethod;
+
/** Utilities for vector validation. */
public class ValidateUtil {
@@ -42,6 +44,7 @@ public static void validateOrThrow(boolean expression, String errorMessage) {
* @param args the error message arguments.
* @throws ValidateException if the expression evaluates to false.
*/
+ @FormatMethod
public static void validateOrThrow(boolean expression, String errorMessage, Object... args) {
if (!expression) {
throw new ValidateException(String.format(errorMessage, args));
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorBufferVisitor.java b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorBufferVisitor.java
index 0c9140c360d..e46f5f9b981 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorBufferVisitor.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorBufferVisitor.java
@@ -131,7 +131,9 @@ public Void visit(BaseVariableWidthVector vector, Void value) {
int lastOffset =
valueCount == 0
? 0
- : vector.getOffsetBuffer().getInt(valueCount * BaseVariableWidthVector.OFFSET_WIDTH);
+ : vector
+ .getOffsetBuffer()
+ .getInt((long) valueCount * BaseVariableWidthVector.OFFSET_WIDTH);
validateDataBuffer(vector, lastOffset);
return null;
}
@@ -172,7 +174,9 @@ public Void visit(ListVector vector, Void value) {
int lastOffset =
valueCount == 0
? 0
- : vector.getOffsetBuffer().getInt(valueCount * BaseVariableWidthVector.OFFSET_WIDTH);
+ : vector
+ .getOffsetBuffer()
+ .getInt((long) valueCount * BaseVariableWidthVector.OFFSET_WIDTH);
int dataVectorLength = dataVector == null ? 0 : dataVector.getValueCount();
validateOrThrow(
dataVectorLength >= lastOffset,
@@ -219,7 +223,7 @@ public Void visit(LargeListVector vector, Void value) {
? 0
: vector
.getOffsetBuffer()
- .getLong(valueCount * BaseLargeVariableWidthVector.OFFSET_WIDTH);
+ .getLong((long) valueCount * BaseLargeVariableWidthVector.OFFSET_WIDTH);
int dataVectorLength = dataVector == null ? 0 : dataVector.getValueCount();
validateOrThrow(
dataVectorLength >= lastOffset,
@@ -283,6 +287,7 @@ public Void visit(NullVector vector, Void value) {
}
@Override
+ @SuppressWarnings("VoidUsed")
public Void visit(ExtensionTypeVector> vector, Void value) {
vector.getUnderlyingVector().accept(this, value);
return null;
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorDataVisitor.java b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorDataVisitor.java
index c62bff79f77..2cf0871fcc8 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorDataVisitor.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorDataVisitor.java
@@ -46,7 +46,7 @@ private void validateOffsetBuffer(ValueVector vector, int valueCount) {
// verify that the values in the offset buffer is non-decreasing
int prevValue = offsetBuffer.getInt(0);
for (int i = 1; i <= valueCount; i++) {
- int curValue = offsetBuffer.getInt(i * 4);
+ int curValue = offsetBuffer.getInt(i * 4L);
validateOrThrow(
curValue >= 0,
"The value at position %s of the offset buffer is negative: %s.",
@@ -202,6 +202,7 @@ public Void visit(NullVector vector, Void value) {
}
@Override
+ @SuppressWarnings("VoidUsed")
public Void visit(ExtensionTypeVector> vector, Void value) {
vector.getUnderlyingVector().accept(this, value);
return null;
diff --git a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorVisitor.java b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorVisitor.java
index 5004ba488ca..71f49672bd2 100644
--- a/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorVisitor.java
+++ b/java/vector/src/main/java/org/apache/arrow/vector/validate/ValidateVectorVisitor.java
@@ -79,7 +79,7 @@ public Void visit(BaseVariableWidthVector vector, Void value) {
int lastOffset =
vector
.getOffsetBuffer()
- .getInt(vector.getValueCount() * BaseVariableWidthVector.OFFSET_WIDTH);
+ .getInt((long) vector.getValueCount() * BaseVariableWidthVector.OFFSET_WIDTH);
if (firstOffset < 0 || lastOffset < 0) {
throw new IllegalArgumentException("Negative offsets in vector");
@@ -136,7 +136,7 @@ public Void visit(ListVector vector, Void value) {
int lastOffset =
vector
.getOffsetBuffer()
- .getInt(vector.getValueCount() * BaseVariableWidthVector.OFFSET_WIDTH);
+ .getInt((long) vector.getValueCount() * BaseVariableWidthVector.OFFSET_WIDTH);
if (firstOffset < 0 || lastOffset < 0) {
throw new IllegalArgumentException("Negative offsets in list vector");
@@ -169,7 +169,7 @@ public Void visit(LargeListVector vector, Void value) {
if (vector.getValueCount() > 0) {
ArrowBuf offsetBuf = vector.getOffsetBuffer();
- long minBufferSize = (vector.getValueCount() + 1) * LargeListVector.OFFSET_WIDTH;
+ long minBufferSize = (long) (vector.getValueCount() + 1) * LargeListVector.OFFSET_WIDTH;
if (offsetBuf.capacity() < minBufferSize) {
throw new IllegalArgumentException(
@@ -184,7 +184,9 @@ public Void visit(LargeListVector vector, Void value) {
long firstOffset = vector.getOffsetBuffer().getLong(0);
long lastOffset =
- vector.getOffsetBuffer().getLong(vector.getValueCount() * LargeListVector.OFFSET_WIDTH);
+ vector
+ .getOffsetBuffer()
+ .getLong((long) vector.getValueCount() * LargeListVector.OFFSET_WIDTH);
if (firstOffset < 0 || lastOffset < 0) {
throw new IllegalArgumentException("Negative offsets in list vector");
@@ -314,6 +316,7 @@ public Void visit(NullVector vector, Void value) {
}
@Override
+ @SuppressWarnings("VoidUsed")
public Void visit(ExtensionTypeVector> vector, Void value) {
vector.getUnderlyingVector().accept(this, value);
return null;
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestCopyFrom.java b/java/vector/src/test/java/org/apache/arrow/vector/TestCopyFrom.java
index bd0b44a1445..abcc9323021 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestCopyFrom.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestCopyFrom.java
@@ -180,7 +180,7 @@ public void testCopyFromWithNulls1() {
/* set lesser initial capacity than actually needed
* to trigger reallocs in copyFromSafe()
*/
- vector2.allocateNew((initialCapacity / 4) * 10, initialCapacity / 4);
+ vector2.allocateNew((initialCapacity / 4) * 10L, initialCapacity / 4);
capacity = vector2.getValueCapacity();
assertTrue(capacity >= initialCapacity / 4);
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 c155ab98fa2..dbbff1aae6a 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
@@ -380,8 +380,8 @@ private void verifyWritingArrowBufWithBigEndianBytes(
decimalVector.allocateNew();
for (int i = 0; i < expectedValues.length; i++) {
byte[] bigEndianBytes = expectedValues[i].unscaledValue().toByteArray();
- buf.setBytes(length * i, bigEndianBytes, 0, bigEndianBytes.length);
- decimalVector.setBigEndianSafe(i, length * i, buf, bigEndianBytes.length);
+ buf.setBytes((long) length * i, bigEndianBytes, 0, bigEndianBytes.length);
+ decimalVector.setBigEndianSafe(i, (long) length * i, buf, bigEndianBytes.length);
}
decimalVector.setValueCount(3);
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestDecimalVector.java b/java/vector/src/test/java/org/apache/arrow/vector/TestDecimalVector.java
index d5310bad0ea..8f839a693eb 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestDecimalVector.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestDecimalVector.java
@@ -376,8 +376,8 @@ private void verifyWritingArrowBufWithBigEndianBytes(
decimalVector.allocateNew();
for (int i = 0; i < expectedValues.length; i++) {
byte[] bigEndianBytes = expectedValues[i].unscaledValue().toByteArray();
- buf.setBytes(length * i, bigEndianBytes, 0, bigEndianBytes.length);
- decimalVector.setBigEndianSafe(i, length * i, buf, bigEndianBytes.length);
+ buf.setBytes((long) length * i, bigEndianBytes, 0, bigEndianBytes.length);
+ decimalVector.setBigEndianSafe(i, (long) length * i, buf, bigEndianBytes.length);
}
decimalVector.setValueCount(3);
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListVector.java b/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListVector.java
index 101d942d2a4..0f45d80b748 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListVector.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListVector.java
@@ -773,7 +773,7 @@ public void testSetInitialCapacity() {
try (final LargeListVector vector = LargeListVector.empty("", allocator)) {
vector.addOrGetVector(FieldType.nullable(MinorType.INT.getType()));
- /**
+ /*
* use the default multiplier of 5, 512 * 5 => 2560 * 4 => 10240 bytes => 16KB => 4096 value
* capacity.
*/
@@ -788,7 +788,7 @@ public void testSetInitialCapacity() {
assertEquals(512, vector.getValueCapacity());
assertTrue(vector.getDataVector().getValueCapacity() >= 512 * 4);
- /**
+ /*
* inner value capacity we pass to data vector is 512 * 0.1 => 51 For an int vector this is
* 204 bytes of memory for data buffer and 7 bytes for validity buffer. and with power of 2
* allocation, we allocate 256 bytes and 8 bytes for the data buffer and validity buffer of
@@ -799,7 +799,7 @@ public void testSetInitialCapacity() {
assertEquals(512, vector.getValueCapacity());
assertTrue(vector.getDataVector().getValueCapacity() >= 51);
- /**
+ /*
* inner value capacity we pass to data vector is 512 * 0.01 => 5 For an int vector this is 20
* bytes of memory for data buffer and 1 byte for validity buffer. and with power of 2
* allocation, we allocate 32 bytes and 1 bytes for the data buffer and validity buffer of the
@@ -810,7 +810,7 @@ public void testSetInitialCapacity() {
assertEquals(512, vector.getValueCapacity());
assertTrue(vector.getDataVector().getValueCapacity() >= 5);
- /**
+ /*
* inner value capacity we pass to data vector is 5 * 0.1 => 0 which is then rounded off to 1.
* So we pass value count as 1 to the inner int vector. the offset buffer of the list vector
* is allocated for 6 values which is 24 bytes and then rounded off to 32 bytes (8 values) the
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListViewVector.java b/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListViewVector.java
index 26e7bb4a0d3..44f6b56d378 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListViewVector.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestLargeListViewVector.java
@@ -1653,7 +1653,7 @@ private int validateSizeBufferAndCalculateMinOffset(
for (int i = 0; i < splitLength; i++) {
fromDataLength = fromSizeBuffer.getInt((long) (start + i) * LargeListViewVector.SIZE_WIDTH);
- toDataLength = toSizeBuffer.getInt((long) (i) * LargeListViewVector.SIZE_WIDTH);
+ toDataLength = toSizeBuffer.getInt((long) i * LargeListViewVector.SIZE_WIDTH);
/* validate size */
assertEquals(
@@ -1683,7 +1683,7 @@ private void validateOffsetBuffer(
for (int i = 0; i < splitLength; i++) {
offset1 = fromOffsetBuffer.getInt((long) (start + i) * LargeListViewVector.OFFSET_WIDTH);
- offset2 = toOffsetBuffer.getInt((long) (i) * LargeListViewVector.OFFSET_WIDTH);
+ offset2 = toOffsetBuffer.getInt((long) i * LargeListViewVector.OFFSET_WIDTH);
assertEquals(
offset1 - minOffset,
offset2,
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestListViewVector.java b/java/vector/src/test/java/org/apache/arrow/vector/TestListViewVector.java
index 639585fc48d..490090177c0 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestListViewVector.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestListViewVector.java
@@ -384,12 +384,6 @@ public void testNestedListVector() throws Exception {
}
}
- private void setValuesInBuffer(int[] bufValues, ArrowBuf buffer, long bufWidth) {
- for (int i = 0; i < bufValues.length; i++) {
- buffer.setInt(i * bufWidth, bufValues[i]);
- }
- }
-
/*
* Setting up the buffers directly needs to be validated with the base method used in
* the ListVector class where we use the approach of startListView(),
@@ -1667,7 +1661,7 @@ private int validateSizeBufferAndCalculateMinOffset(
for (int i = 0; i < splitLength; i++) {
fromDataLength = fromSizeBuffer.getInt((long) (start + i) * ListViewVector.SIZE_WIDTH);
- toDataLength = toSizeBuffer.getInt((long) (i) * ListViewVector.SIZE_WIDTH);
+ toDataLength = toSizeBuffer.getInt((long) i * ListViewVector.SIZE_WIDTH);
/* validate size */
assertEquals(
@@ -1696,7 +1690,7 @@ private void validateOffsetBuffer(
for (int i = 0; i < splitLength; i++) {
offset1 = fromOffsetBuffer.getInt((long) (start + i) * ListViewVector.OFFSET_WIDTH);
- offset2 = toOffsetBuffer.getInt((long) (i) * ListViewVector.OFFSET_WIDTH);
+ offset2 = toOffsetBuffer.getInt((long) i * ListViewVector.OFFSET_WIDTH);
assertEquals(
offset1 - minOffset,
offset2,
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestPeriodDuration.java b/java/vector/src/test/java/org/apache/arrow/vector/TestPeriodDuration.java
index 37f59f82cbd..68641027138 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestPeriodDuration.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestPeriodDuration.java
@@ -54,19 +54,22 @@ public void testToISO8601IntervalString() {
new PeriodDuration(Period.ZERO, Duration.ofNanos(123)).toISO8601IntervalString());
assertEquals(
"PT1.000000123S",
- new PeriodDuration(Period.ZERO, Duration.ofSeconds(1).withNanos(123))
+ new PeriodDuration(Period.ZERO, Duration.ofSeconds(Duration.ofSeconds(1).getSeconds(), 123))
.toISO8601IntervalString());
assertEquals(
"PT1H1.000000123S",
- new PeriodDuration(Period.ZERO, Duration.ofSeconds(3601).withNanos(123))
+ new PeriodDuration(
+ Period.ZERO, Duration.ofSeconds(Duration.ofSeconds(3601).getSeconds(), 123))
.toISO8601IntervalString());
assertEquals(
"PT24H1M1.000000123S",
- new PeriodDuration(Period.ZERO, Duration.ofSeconds(86461).withNanos(123))
+ new PeriodDuration(
+ Period.ZERO, Duration.ofSeconds(Duration.ofSeconds(86461).getSeconds(), 123))
.toISO8601IntervalString());
assertEquals(
"P1Y2M3DT24H1M1.000000123S",
- new PeriodDuration(Period.of(1, 2, 3), Duration.ofSeconds(86461).withNanos(123))
+ new PeriodDuration(
+ Period.of(1, 2, 3), Duration.ofSeconds(Duration.ofSeconds(86461).getSeconds(), 123))
.toISO8601IntervalString());
assertEquals(
@@ -77,11 +80,13 @@ public void testToISO8601IntervalString() {
new PeriodDuration(Period.ZERO, Duration.ofNanos(-123)).toISO8601IntervalString());
assertEquals(
"PT-24H-1M-0.999999877S",
- new PeriodDuration(Period.ZERO, Duration.ofSeconds(-86461).withNanos(123))
+ new PeriodDuration(
+ Period.ZERO, Duration.ofSeconds(Duration.ofSeconds(-86461).getSeconds(), 123))
.toISO8601IntervalString());
assertEquals(
"P-1Y-2M-3DT-0.999999877S",
- new PeriodDuration(Period.of(-1, -2, -3), Duration.ofSeconds(-1).withNanos(123))
+ new PeriodDuration(
+ Period.of(-1, -2, -3), Duration.ofSeconds(Duration.ofSeconds(-1).getSeconds(), 123))
.toISO8601IntervalString());
}
@@ -96,7 +101,8 @@ public void testTemporalAccessor() {
assertEquals(LocalDateTime.of(2024, 1, 2, 3, 3), pd2.subtractFrom(dateTime));
PeriodDuration pd3 =
- new PeriodDuration(Period.of(1, 2, 3), Duration.ofSeconds(86461).withNanos(123));
+ new PeriodDuration(
+ Period.of(1, 2, 3), Duration.ofSeconds(Duration.ofSeconds(86461).getSeconds(), 123));
assertEquals(pd3.get(ChronoUnit.YEARS), 1);
assertEquals(pd3.get(ChronoUnit.MONTHS), 2);
assertEquals(pd3.get(ChronoUnit.DAYS), 3);
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestTypeLayout.java b/java/vector/src/test/java/org/apache/arrow/vector/TestTypeLayout.java
index 75c6df1d6a4..d56487d8763 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestTypeLayout.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestTypeLayout.java
@@ -18,6 +18,7 @@
import static org.junit.jupiter.api.Assertions.assertEquals;
+import java.nio.charset.StandardCharsets;
import java.util.Random;
import org.apache.arrow.memory.BufferAllocator;
import org.apache.arrow.memory.RootAllocator;
@@ -175,12 +176,12 @@ public void testTypeBufferCountInVectorsWithVariadicBuffers() {
try (ViewVarCharVector viewVarCharVector = new ViewVarCharVector("myvector", allocator)) {
viewVarCharVector.allocateNew(32, 6);
- viewVarCharVector.setSafe(0, generateRandomString(8).getBytes());
- viewVarCharVector.setSafe(1, generateRandomString(12).getBytes());
- viewVarCharVector.setSafe(2, generateRandomString(14).getBytes());
- viewVarCharVector.setSafe(3, generateRandomString(18).getBytes());
- viewVarCharVector.setSafe(4, generateRandomString(22).getBytes());
- viewVarCharVector.setSafe(5, generateRandomString(24).getBytes());
+ viewVarCharVector.setSafe(0, generateRandomString(8).getBytes(StandardCharsets.UTF_8));
+ viewVarCharVector.setSafe(1, generateRandomString(12).getBytes(StandardCharsets.UTF_8));
+ viewVarCharVector.setSafe(2, generateRandomString(14).getBytes(StandardCharsets.UTF_8));
+ viewVarCharVector.setSafe(3, generateRandomString(18).getBytes(StandardCharsets.UTF_8));
+ viewVarCharVector.setSafe(4, generateRandomString(22).getBytes(StandardCharsets.UTF_8));
+ viewVarCharVector.setSafe(5, generateRandomString(24).getBytes(StandardCharsets.UTF_8));
viewVarCharVector.setValueCount(6);
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestUnionVector.java b/java/vector/src/test/java/org/apache/arrow/vector/TestUnionVector.java
index 6c05073c168..972c2c62cba 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestUnionVector.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestUnionVector.java
@@ -381,6 +381,7 @@ public void testSplitAndTransferWithMixedVectors() throws Exception {
}
@Test
+ @SuppressWarnings("EnumOrdinal")
public void testGetFieldTypeInfo() throws Exception {
Map metadata = new HashMap<>();
metadata.put("key1", "value1");
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestValueVector.java b/java/vector/src/test/java/org/apache/arrow/vector/TestValueVector.java
index 83e470ae258..9220e4c6c91 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestValueVector.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestValueVector.java
@@ -1908,7 +1908,7 @@ public void testSetSafeWithArrowBufNoExcessAllocs() {
}
fromVector.setValueCount(numValues);
ArrowBuf fromDataBuffer = fromVector.getDataBuffer();
- assertTrue(numValues * valueBytesLength <= fromDataBuffer.capacity());
+ assertTrue((long) numValues * valueBytesLength <= fromDataBuffer.capacity());
/*
* Copy the entries one-by-one from 'fromVector' to 'toVector', but use the setSafe with
@@ -2398,11 +2398,11 @@ public void testMultipleClose() {
*/
public static void setBytes(int index, byte[] bytes, VarCharVector vector) {
final int currentOffset =
- vector.offsetBuffer.getInt(index * BaseVariableWidthVector.OFFSET_WIDTH);
+ vector.offsetBuffer.getInt((long) index * BaseVariableWidthVector.OFFSET_WIDTH);
BitVectorHelper.setBit(vector.validityBuffer, index);
vector.offsetBuffer.setInt(
- (index + 1) * BaseVariableWidthVector.OFFSET_WIDTH, currentOffset + bytes.length);
+ (long) (index + 1) * BaseVariableWidthVector.OFFSET_WIDTH, currentOffset + bytes.length);
vector.valueBuffer.setBytes(currentOffset, bytes, 0, bytes.length);
}
@@ -2669,8 +2669,8 @@ public void testGetPointerVariableWidth() {
try (VarCharVector vec1 = new VarCharVector("vec1", allocator);
VarCharVector vec2 = new VarCharVector("vec2", allocator)) {
- vec1.allocateNew(sampleData.length * 10, sampleData.length);
- vec2.allocateNew(sampleData.length * 10, sampleData.length);
+ vec1.allocateNew(sampleData.length * 10L, sampleData.length);
+ vec2.allocateNew(sampleData.length * 10L, sampleData.length);
for (int i = 0; i < sampleData.length; i++) {
String str = sampleData[i];
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestValueVectorIterable.java b/java/vector/src/test/java/org/apache/arrow/vector/TestValueVectorIterable.java
index e6b79e89b99..3d75b56640b 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestValueVectorIterable.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestValueVectorIterable.java
@@ -172,7 +172,7 @@ public void testDurationVectorIterable() {
durationVector.setSafe(2, 555);
durationVector.setValueCount(3);
- final Duration value1 = Duration.ofMillis(30000);
+ final Duration value1 = Duration.ofSeconds(30);
final Duration value3 = Duration.ofMillis(555);
assertThat(
durationVector.getValueIterable(),
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestVarCharViewVector.java b/java/vector/src/test/java/org/apache/arrow/vector/TestVarCharViewVector.java
index 308431fdeb9..d418fa92ca9 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestVarCharViewVector.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestVarCharViewVector.java
@@ -544,7 +544,7 @@ public void testSetSafeWithArrowBufNoExcessAllocs() {
}
fromVector.setValueCount(numValues);
ArrowBuf fromDataBuffer = fromVector.getDataBuffer();
- assertTrue(numValues * valueBytesLength <= fromDataBuffer.capacity());
+ assertTrue((long) numValues * valueBytesLength <= fromDataBuffer.capacity());
/*
* Copy the entries one-by-one from 'fromVector' to 'toVector', but use the setSafe with
@@ -1668,20 +1668,20 @@ static Stream vectorCreatorProvider() {
return Stream.of(
Arguments.of(
(Function)
- (allocator ->
+ allocator ->
newVector(
ViewVarBinaryVector.class,
EMPTY_SCHEMA_PATH,
Types.MinorType.VIEWVARBINARY,
- allocator))),
+ allocator)),
Arguments.of(
(Function)
- (allocator ->
+ allocator ->
newVector(
ViewVarCharVector.class,
EMPTY_SCHEMA_PATH,
Types.MinorType.VIEWVARCHAR,
- allocator))));
+ allocator)));
}
@ParameterizedTest
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/TestVectorUnloadLoad.java b/java/vector/src/test/java/org/apache/arrow/vector/TestVectorUnloadLoad.java
index 6121fb67fef..4638c9fb7a9 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/TestVectorUnloadLoad.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/TestVectorUnloadLoad.java
@@ -216,7 +216,7 @@ public void testLoadValidityBuffer() throws IOException {
ArrowBuf[] values = new ArrowBuf[4];
for (int i = 0; i < 4; i += 2) {
ArrowBuf buf1 = allocator.buffer(BitVectorHelper.getValidityBufferSize(count));
- ArrowBuf buf2 = allocator.buffer(count * 4); // integers
+ ArrowBuf buf2 = allocator.buffer(count * 4L); // integers
buf1.setZero(0, buf1.capacity());
buf2.setZero(0, buf2.capacity());
values[i] = buf1;
@@ -228,10 +228,10 @@ public void testLoadValidityBuffer() throws IOException {
BitVectorHelper.setBit(buf1, j);
}
- buf2.setInt(j * 4, j);
+ buf2.setInt(j * 4L, j);
}
- buf1.writerIndex((int) Math.ceil(count / 8));
- buf2.writerIndex(count * 4);
+ buf1.writerIndex((int) Math.ceil(count / 8.0));
+ buf2.writerIndex(count * 4L);
}
/*
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java b/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java
index 3bc02c60298..2c4b06952c6 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/complex/impl/TestComplexCopier.java
@@ -136,8 +136,8 @@ public void testCopyMapVector() {
mapWriter.value().integer().writeInt(i);
mapWriter.endEntry();
mapWriter.startEntry();
- mapWriter.key().decimal().writeDecimal(BigDecimal.valueOf(i * 2));
- mapWriter.value().decimal().writeDecimal(BigDecimal.valueOf(i * 2));
+ mapWriter.key().decimal().writeDecimal(BigDecimal.valueOf(i * 2L));
+ mapWriter.value().decimal().writeDecimal(BigDecimal.valueOf(i * 2L));
mapWriter.endEntry();
mapWriter.endMap();
}
@@ -176,13 +176,13 @@ public void testCopyListVector() {
listWriter.list().startList();
listWriter.list().bigInt().writeBigInt(i);
- listWriter.list().bigInt().writeBigInt(i * 2);
- listWriter.list().bigInt().writeBigInt(i * 3);
+ listWriter.list().bigInt().writeBigInt(i * 2L);
+ listWriter.list().bigInt().writeBigInt(i * 3L);
listWriter.list().endList();
listWriter.list().startList();
- listWriter.list().decimal().writeDecimal(BigDecimal.valueOf(i * 4));
- listWriter.list().decimal().writeDecimal(BigDecimal.valueOf(i * 5));
+ listWriter.list().decimal().writeDecimal(BigDecimal.valueOf(i * 4L));
+ listWriter.list().decimal().writeDecimal(BigDecimal.valueOf(i * 5L));
listWriter.list().endList();
listWriter.endList();
}
@@ -597,7 +597,7 @@ public void testCopyFixedSizedListOfDecimalsVector() {
writer
.decimal()
.writeBigEndianBytesToDecimal(
- BigDecimal.valueOf(i * 4).unscaledValue().toByteArray(), arrowType);
+ BigDecimal.valueOf(i * 4L).unscaledValue().toByteArray(), arrowType);
writer.endList();
}
@@ -631,12 +631,12 @@ public void testCopyUnionListWithDecimal() {
listWriter.setPosition(i);
listWriter.startList();
- listWriter.decimal().writeDecimal(BigDecimal.valueOf(i * 2));
+ listWriter.decimal().writeDecimal(BigDecimal.valueOf(i * 2L));
listWriter.integer().writeInt(i);
listWriter
.decimal()
.writeBigEndianBytesToDecimal(
- BigDecimal.valueOf(i * 3).unscaledValue().toByteArray(),
+ BigDecimal.valueOf(i * 3L).unscaledValue().toByteArray(),
new ArrowType.Decimal(3, 0, 128));
listWriter.endList();
@@ -671,15 +671,15 @@ public void testCopyStructVector() {
structWriter.setPosition(i);
structWriter.start();
structWriter.integer("int").writeInt(i);
- structWriter.decimal("dec", 0, 38).writeDecimal(BigDecimal.valueOf(i * 2));
+ structWriter.decimal("dec", 0, 38).writeDecimal(BigDecimal.valueOf(i * 2L));
StructWriter innerStructWriter = structWriter.struct("struc");
innerStructWriter.start();
innerStructWriter.integer("innerint").writeInt(i * 3);
- innerStructWriter.decimal("innerdec", 0, 38).writeDecimal(BigDecimal.valueOf(i * 4));
+ innerStructWriter.decimal("innerdec", 0, 38).writeDecimal(BigDecimal.valueOf(i * 4L));
innerStructWriter
.decimal("innerdec", 0, 38)
.writeBigEndianBytesToDecimal(
- BigDecimal.valueOf(i * 4).unscaledValue().toByteArray(),
+ BigDecimal.valueOf(i * 4L).unscaledValue().toByteArray(),
new ArrowType.Decimal(3, 0, 128));
innerStructWriter.end();
structWriter.end();
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/ipc/BaseFileTest.java b/java/vector/src/test/java/org/apache/arrow/vector/ipc/BaseFileTest.java
index 281f050dfb6..d7fba5c3b27 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/ipc/BaseFileTest.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/ipc/BaseFileTest.java
@@ -510,7 +510,7 @@ protected VectorSchemaRoot writeDecimalData(BufferAllocator bufferAllocator) {
for (int i = 0; i < count; i++) {
decimalVector1.setSafe(i, new BigDecimal(BigInteger.valueOf(i), 3));
- decimalVector2.setSafe(i, new BigDecimal(BigInteger.valueOf(i * (1 << 10)), 2));
+ decimalVector2.setSafe(i, new BigDecimal(BigInteger.valueOf(i * ((long) (1 << 10))), 2));
decimalVector3.setSafe(i, new BigDecimal(BigInteger.valueOf(i * 1111111111111111L), 8));
}
@@ -543,7 +543,7 @@ protected void validateDecimalData(VectorSchemaRoot root) {
// Verify decimal 2 vector
readValue = decimalVector2.getObject(i);
type = (ArrowType.Decimal) decimalVector2.getField().getType();
- genValue = new BigDecimal(BigInteger.valueOf(i * (1 << 10)), type.getScale());
+ genValue = new BigDecimal(BigInteger.valueOf(i * ((long) (1 << 10))), type.getScale());
assertEquals(genValue, readValue);
// Verify decimal 3 vector
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java b/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java
index 74ff95d41d6..c686b124c81 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/ipc/TestArrowReaderWriter.java
@@ -783,7 +783,7 @@ public void testReadInterleavedData() throws IOException {
Collections.singletonList(dictVector1),
dictVector1.getValueCount());
ArrowDictionaryBatch dictionaryBatch1 =
- new ArrowDictionaryBatch(1, new VectorUnloader(dictRoot1).getRecordBatch());
+ new ArrowDictionaryBatch(1, new VectorUnloader(dictRoot1).getRecordBatch(), false);
MessageSerializer.serialize(out, dictionaryBatch1);
dictionaryBatch1.close();
dictRoot1.close();
@@ -799,7 +799,7 @@ public void testReadInterleavedData() throws IOException {
Collections.singletonList(dictVector2),
dictVector2.getValueCount());
ArrowDictionaryBatch dictionaryBatch2 =
- new ArrowDictionaryBatch(2, new VectorUnloader(dictRoot2).getRecordBatch());
+ new ArrowDictionaryBatch(2, new VectorUnloader(dictRoot2).getRecordBatch(), false);
MessageSerializer.serialize(out, dictionaryBatch2);
dictionaryBatch2.close();
dictRoot2.close();
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/pojo/TestConvert.java b/java/vector/src/test/java/org/apache/arrow/vector/pojo/TestConvert.java
index 62e5355d05c..12d49206c05 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/pojo/TestConvert.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/pojo/TestConvert.java
@@ -101,7 +101,10 @@ public void list() throws Exception {
org.apache.arrow.vector.types.pojo.Schema schema =
new org.apache.arrow.vector.types.pojo.Schema(tempSchema.getFields());
schemaBuilder.finish(schema.getSchema(schemaBuilder));
- Schema finalSchema = Schema.deserialize(ByteBuffer.wrap(schemaBuilder.sizedByteArray()));
+ Schema finalSchema =
+ Schema.convertSchema(
+ org.apache.arrow.flatbuf.Schema.getRootAsSchema(
+ ByteBuffer.wrap(schemaBuilder.sizedByteArray())));
assertFalse(finalSchema.toString().contains("[DEFAULT]"));
}
@@ -131,6 +134,7 @@ public void schemaMetadata() {
}
@Test
+ @SuppressWarnings("EnumOrdinal")
public void nestedSchema() {
java.util.List children = new ArrayList<>();
children.add(new Field("child1", FieldType.nullable(Utf8.INSTANCE), null));
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/table/RowTest.java b/java/vector/src/test/java/org/apache/arrow/vector/table/RowTest.java
index c1125d407e1..cc9a6ad8fc6 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/table/RowTest.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/table/RowTest.java
@@ -790,6 +790,7 @@ void testSimpleDenseUnionVector() {
}
@Test
+ @SuppressWarnings("FloatingPointLiteralPrecision")
void testExtensionTypeVector() {
TestExtensionType.LocationVector vector =
new TestExtensionType.LocationVector("location", allocator);
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/testing/TestValueVectorPopulator.java b/java/vector/src/test/java/org/apache/arrow/vector/testing/TestValueVectorPopulator.java
index c0e2ae252e0..727737c260a 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/testing/TestValueVectorPopulator.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/testing/TestValueVectorPopulator.java
@@ -141,7 +141,7 @@ public void testPopulateDateMilliVector() {
if (i % 2 == 0) {
vector1.setNull(i);
} else {
- vector1.set(i, i * 1000);
+ vector1.set(i, i * 1000L);
}
}
vector1.setValueCount(10);
@@ -334,7 +334,7 @@ public void testPopulateTimeMicroVector() {
if (i % 2 == 0) {
vector1.setNull(i);
} else {
- vector1.set(i, i * 10000);
+ vector1.set(i, i * 10000L);
}
}
vector1.setValueCount(10);
@@ -372,7 +372,7 @@ public void testPopulateTimeNanoVector() {
if (i % 2 == 0) {
vector1.setNull(i);
} else {
- vector1.set(i, i * 10000);
+ vector1.set(i, i * 10000L);
}
}
vector1.setValueCount(10);
@@ -410,7 +410,7 @@ public void testPopulateTimeStampMicroVector() {
if (i % 2 == 0) {
vector1.setNull(i);
} else {
- vector1.set(i, i * 10000);
+ vector1.set(i, i * 10000L);
}
}
vector1.setValueCount(10);
@@ -429,7 +429,7 @@ public void testPopulateTimeStampMilliVector() {
if (i % 2 == 0) {
vector1.setNull(i);
} else {
- vector1.set(i, i * 10000);
+ vector1.set(i, i * 10000L);
}
}
vector1.setValueCount(10);
@@ -448,7 +448,7 @@ public void testPopulateTimeStampNanoVector() {
if (i % 2 == 0) {
vector1.setNull(i);
} else {
- vector1.set(i, i * 10000);
+ vector1.set(i, i * 10000L);
}
}
vector1.setValueCount(10);
@@ -467,7 +467,7 @@ public void testPopulateTimeStampSecVector() {
if (i % 2 == 0) {
vector1.setNull(i);
} else {
- vector1.set(i, i * 100);
+ vector1.set(i, i * 100L);
}
}
vector1.setValueCount(10);
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 8f54a6e5d74..19eeea1dd30 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
@@ -194,6 +194,7 @@ public void testNullCheck() {
/** Test that a custom Location type can be round-tripped through a temporary file. */
@Test
+ @SuppressWarnings("FloatingPointLiteralPrecision")
public void roundtripLocation() throws IOException {
ExtensionTypeRegistry.register(new LocationType());
final Schema schema =
diff --git a/java/vector/src/test/java/org/apache/arrow/vector/util/TestValidator.java b/java/vector/src/test/java/org/apache/arrow/vector/util/TestValidator.java
index a7a4035550c..258a83142f4 100644
--- a/java/vector/src/test/java/org/apache/arrow/vector/util/TestValidator.java
+++ b/java/vector/src/test/java/org/apache/arrow/vector/util/TestValidator.java
@@ -25,6 +25,7 @@
public class TestValidator {
@Test
+ @SuppressWarnings("FloatingPointLiteralPrecision")
public void testFloatComp() {
assertTrue(equalEnough(912.4140000000002F, 912.414F));
assertTrue(equalEnough(912.4140000000002D, 912.414D));