Skip to content

Commit 5aaf5d0

Browse files
committed
GH-3213: Add the configuration for ByteStreamSplit encoding
1 parent 76b6469 commit 5aaf5d0

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

parquet-hadoop/src/test/java/org/apache/parquet/hadoop/TestParquetWriter.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -631,9 +631,7 @@ public void testByteStreamSplitEncodingControl() throws Exception {
631631
.withByteStreamSplitEncoding(true)
632632
.withByteStreamSplitEncoding("int32_field", true)
633633
.build()) {
634-
writer.write(factory.newGroup()
635-
.append("float_field", 0.3f)
636-
.append("int32_field", 42));
634+
writer.write(factory.newGroup().append("float_field", 0.3f).append("int32_field", 42));
637635
}
638636

639637
try (ParquetFileReader reader = ParquetFileReader.open(HadoopInputFile.fromPath(path, new Configuration()))) {
@@ -645,7 +643,7 @@ public void testByteStreamSplitEncodingControl() throws Exception {
645643
}
646644

647645
try (ParquetReader<Group> reader =
648-
ParquetReader.builder(new GroupReadSupport(), path).build()) {
646+
ParquetReader.builder(new GroupReadSupport(), path).build()) {
649647
Group group = reader.read();
650648
assertEquals(0.3f, group.getFloat("float_field", 0), 0.0);
651649
assertEquals(42, group.getInteger("int32_field", 0));

0 commit comments

Comments
 (0)