diff --git a/java/tsfile/src/main/java/org/apache/tsfile/write/record/Tablet.java b/java/tsfile/src/main/java/org/apache/tsfile/write/record/Tablet.java index e02131975..253d99b65 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/write/record/Tablet.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/write/record/Tablet.java @@ -946,7 +946,10 @@ public Object getValue(int i, int j) { case BOOLEAN: return ((boolean[]) values[j])[i]; case INT64: + case TIMESTAMP: return ((long[]) values[j])[i]; + case DATE: + return ((LocalDate[]) values[j])[i]; default: throw new IllegalArgumentException("Unsupported type: " + schemas.get(j).getType()); } diff --git a/java/tsfile/src/test/java/org/apache/tsfile/write/record/TabletTest.java b/java/tsfile/src/test/java/org/apache/tsfile/write/record/TabletTest.java index b5dcd3b08..325fb3018 100644 --- a/java/tsfile/src/test/java/org/apache/tsfile/write/record/TabletTest.java +++ b/java/tsfile/src/test/java/org/apache/tsfile/write/record/TabletTest.java @@ -68,7 +68,12 @@ public void testSerializationAndDeSerialization() { try { final ByteBuffer byteBuffer = tablet.serialize(); final Tablet newTablet = Tablet.deserialize(byteBuffer); - assertEquals(newTablet, tablet); + assertEquals(tablet, newTablet); + for (int i = 0; i < rowSize; i++) { + for (int j = 0; j < tablet.getSchemas().size(); j++) { + assertEquals(tablet.getValue(i, j), newTablet.getValue(i, j)); + } + } } catch (final Exception e) { e.printStackTrace(); fail(); @@ -132,7 +137,12 @@ public void testSerializationAndDeSerializationWithMoreData() { try { final ByteBuffer byteBuffer = tablet.serialize(); final Tablet newTablet = Tablet.deserialize(byteBuffer); - assertEquals(newTablet, tablet); + assertEquals(tablet, newTablet); + for (int i = 0; i < rowSize; i++) { + for (int j = 0; j < tablet.getSchemas().size(); j++) { + assertEquals(tablet.getValue(i, j), newTablet.getValue(i, j)); + } + } } catch (final Exception e) { e.printStackTrace(); fail();