This is an automated email from the ASF dual-hosted git repository.
hxd pushed a commit to branch refactor_overflow_2
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/refactor_overflow_2 by this
push:
new 9feb2cd comment an abandoned ut
9feb2cd is described below
commit 9feb2cd9e9b021944b9bb4bb6c39afc93046866e
Author: xiangdong huang <[email protected]>
AuthorDate: Wed Mar 20 23:38:09 2019 +0800
comment an abandoned ut
---
.../db/engine/tsfiledata/TsFileProcessorTest.java | 68 +++++++++++-----------
1 file changed, 34 insertions(+), 34 deletions(-)
diff --git
a/iotdb/src/test/java/org/apache/iotdb/db/engine/tsfiledata/TsFileProcessorTest.java
b/iotdb/src/test/java/org/apache/iotdb/db/engine/tsfiledata/TsFileProcessorTest.java
index 6aa9f1f..f25e766 100644
---
a/iotdb/src/test/java/org/apache/iotdb/db/engine/tsfiledata/TsFileProcessorTest.java
+++
b/iotdb/src/test/java/org/apache/iotdb/db/engine/tsfiledata/TsFileProcessorTest.java
@@ -117,40 +117,40 @@ public class TsFileProcessorTest {
IoTDBDescriptor.getInstance().getConfig().setBufferwriteFileSizeThreshold(oldBufferwriteFileSizeThreshold);
}
- @Test
- public void insert()
- throws BufferWriteProcessorException, IOException, ExecutionException,
InterruptedException, FileNodeProcessorException, FileNodeManagerException,
PathErrorException, MetadataArgsErrorException {
-
- Assert.assertTrue(processor.insert("root.test.d1", "s1", 10, "5.0"));
- Assert.assertTrue(processor.insert("root.test.d1", "s2", 10, "5.0"));
- Assert.assertTrue(processor.insert("root.test.d1", "s1", 12, "5.0"));
- Future<Boolean> ok = processor.flush();
- ok.get();
- ok = processor.flush();
- Assert.assertTrue(ok instanceof ImmediateFuture);
- ok.get();
- ok = processor.flush();
- Assert.assertTrue(ok instanceof ImmediateFuture);
- ok.get();
-
- //let's rewrite timestamp =12 again..
- Assert.assertFalse(processor.insert("root.test.d1", "s1", 12, "5.0"));
- processor.delete("root.test.d1", "s1",12);
- Assert.assertTrue(processor.insert("root.test.d1", "s1", 12, "5.0"));
- Assert.assertTrue(processor.insert("root.test.d1", "s1", 13, "5.0"));
- Assert.assertTrue(processor.insert("root.test.d2", "s1", 10, "5.0"));
- Assert.assertTrue(processor.insert(new TSRecord(14,
"root.test.d1").addTuple(new FloatDataPoint("s1", 6.0f))));
- processor.delete("root.test.d1", "s1",12);
- processor.delete("root.test.d3", "s1",12);
-
-
- QueryExpression qe = QueryExpression.create(Collections.singletonList(new
Path("root.test.d1", "s1")), null);
- QueryDataSet result = queryManager.query(qe, processor);
- while (result.hasNext()) {
- RowRecord record = result.next();
- System.out.println(record.getTimestamp() +"," +
record.getFields().get(0).getFloatV());
- }
- }
+// @Test
+// public void insert()
+// throws BufferWriteProcessorException, IOException, ExecutionException,
InterruptedException, FileNodeProcessorException, FileNodeManagerException,
PathErrorException, MetadataArgsErrorException {
+//
+// Assert.assertTrue(processor.insert("root.test.d1", "s1", 10, "5.0"));
+// Assert.assertTrue(processor.insert("root.test.d1", "s2", 10, "5.0"));
+// Assert.assertTrue(processor.insert("root.test.d1", "s1", 12, "5.0"));
+// Future<Boolean> ok = processor.flush();
+// ok.get();
+// ok = processor.flush();
+// Assert.assertTrue(ok instanceof ImmediateFuture);
+// ok.get();
+// ok = processor.flush();
+// Assert.assertTrue(ok instanceof ImmediateFuture);
+// ok.get();
+//
+// //let's rewrite timestamp =12 again..
+// Assert.assertFalse(processor.insert("root.test.d1", "s1", 12, "5.0"));
+// processor.delete("root.test.d1", "s1",12);
+// Assert.assertTrue(processor.insert("root.test.d1", "s1", 12, "5.0"));
+// Assert.assertTrue(processor.insert("root.test.d1", "s1", 13, "5.0"));
+// Assert.assertTrue(processor.insert("root.test.d2", "s1", 10, "5.0"));
+// Assert.assertTrue(processor.insert(new TSRecord(14,
"root.test.d1").addTuple(new FloatDataPoint("s1", 6.0f))));
+// processor.delete("root.test.d1", "s1",12);
+// processor.delete("root.test.d3", "s1",12);
+//
+//
+// QueryExpression qe =
QueryExpression.create(Collections.singletonList(new Path("root.test.d1",
"s1")), null);
+// QueryDataSet result = queryManager.query(qe, processor);
+// while (result.hasNext()) {
+// RowRecord record = result.next();
+// System.out.println(record.getTimestamp() +"," +
record.getFields().get(0).getFloatV());
+// }
+// }
