Skip to content

Commit 1718bc7

Browse files
committed
fix code format
1 parent 662917a commit 1718bc7

File tree

2 files changed

+3
-8
lines changed

2 files changed

+3
-8
lines changed

adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/BinaryConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public void consume(InputStream is) throws IOException {
7272
BitVectorHelper.setBit(vector.getValidityBuffer(), currentIndex);
7373
}
7474
offsetBuffer.setInt(
75-
(currentIndex + 1) * ((long) VarBinaryVector.OFFSET_WIDTH), startOffset + dataLength);
75+
(currentIndex + 1) * ((long) VarBinaryVector.OFFSET_WIDTH), startOffset + dataLength);
7676
vector.setLastSet(currentIndex);
7777
}
7878

adapter/jdbc/src/test/java/org/apache/arrow/adapter/jdbc/consumer/BinaryConsumerTest.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -124,14 +124,9 @@ public void testConsumeInputStream() throws IOException {
124124
testRecords[i] = createBytes(DEFAULT_RECORD_BYTE_COUNT);
125125
}
126126
testConsumeInputStream(testRecords, false);
127+
127128
byte[] bytes1 = new byte[] {1, 2, 3};
128129
byte[] bytes2 = new byte[] {4, 5, 6};
129-
testConsumeInputStream(
130-
new byte[][] {
131-
bytes1,
132-
null,
133-
bytes2
134-
},
135-
true);
130+
testConsumeInputStream(new byte[][] {bytes1, null, bytes2}, true);
136131
}
137132
}

0 commit comments

Comments
 (0)