Skip to content

Commit 04bd104

Browse files
committed
more cleanup
1 parent b5c99fa commit 04bd104

File tree

1 file changed

+2
-10
lines changed

1 file changed

+2
-10
lines changed

flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/TimestampResultSetTest.java

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,7 @@
3434
import org.apache.arrow.driver.jdbc.utils.MockFlightSqlProducer;
3535
import org.apache.arrow.memory.BufferAllocator;
3636
import org.apache.arrow.memory.RootAllocator;
37-
import org.apache.arrow.vector.TimeStampMilliTZVector;
38-
import org.apache.arrow.vector.TimeStampMilliVector;
37+
import org.apache.arrow.vector.TimeStampVector;
3938
import org.apache.arrow.vector.VectorSchemaRoot;
4039
import org.apache.arrow.vector.types.TimeUnit;
4140
import org.apache.arrow.vector.types.pojo.ArrowType;
@@ -82,14 +81,7 @@ public static void setup() throws SQLException {
8281
final VectorSchemaRoot root = VectorSchemaRoot.create(QUERY_SCHEMA, allocator)) {
8382
listener.start(root);
8483
root.getFieldVectors()
85-
.forEach(
86-
v -> {
87-
if (v instanceof TimeStampMilliVector) {
88-
((TimeStampMilliVector) v).setSafe(0, firstDay2025.toEpochMilli());
89-
} else if (v instanceof TimeStampMilliTZVector) {
90-
((TimeStampMilliTZVector) v).setSafe(0, firstDay2025.toEpochMilli());
91-
}
92-
});
84+
.forEach(v -> ((TimeStampVector) v).setSafe(0, firstDay2025.toEpochMilli()));
9385
root.setRowCount(1);
9486
listener.putNext();
9587
} catch (final Throwable throwable) {

0 commit comments

Comments
 (0)