This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch testcontainer
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from d13381a add readme for testcontainer
add c131da2 [IOTDB-1254] Trigger module: windowing utility (#2891)
add e656ea5 uncomment the less used configuration (#2993)
add c648e5a Refactor the user documents of `API` (#3032)
add 9b06cae [IOTDB-1303] Group by without aggregation function used in
select clause (#3011)
add 7be35d6 [IOTDB-1317] Log CatchUp always failed du to not check the
follower's match index (#3029)
add 3c64ed9 update config.js (#3039)
add aaa8fec [IOTDB-1199] Support aligned timeseries and device template
(#2802)
add 3e9cd96 try test container
add 908b951 enable github CI for docker
add 09a5bc7 remove duplicated operations in integration-test phase
add 11aaa5b add readme for testcontainer
add 85e9cb7 Merge branch 'testcontainer' of
github.com:apache/incubator-iotdb into testcontainer
No new revisions were added by this update.
Summary of changes:
.github/workflows/main-unix.yml | 2 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 20 +-
.../resources/conf/iotdb-cluster.properties | 58 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 5 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 4 +-
.../cluster/client/sync/SyncClientAdaptor.java | 6 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 76 ++-
.../iotdb/cluster/log/applier/BaseApplier.java | 4 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 48 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 173 +++++-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 21 +-
.../cluster/partition/slot/SlotPartitionTable.java | 5 +-
.../cluster/query/ClusterPhysicalGenerator.java | 7 +
.../iotdb/cluster/query/ClusterPlanRouter.java | 11 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 20 +-
.../cluster/query/reader/ClusterReaderFactory.java | 16 +-
.../apache/iotdb/cluster/server/ClientServer.java | 1 +
.../caller/PullMeasurementSchemaHandler.java | 13 +-
.../cluster/server/member/DataGroupMember.java | 41 +-
.../cluster/server/member/MetaGroupMember.java | 13 -
.../iotdb/cluster/server/member/RaftMember.java | 31 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 8 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 3 +-
.../cluster/client/async/AsyncClientPoolTest.java | 41 +-
.../cluster/client/async/AsyncDataClientTest.java | 18 +
.../client/async/AsyncDataHeartbeatClientTest.java | 18 +
.../cluster/client/async/AsyncMetaClientTest.java | 18 +
.../client/async/AsyncMetaHeartbeatClientTest.java | 18 +
.../cluster/client/sync/SyncClientAdaptorTest.java | 7 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 6 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 9 +-
.../iotdb/cluster/log/LogDispatcherTest.java | 10 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 8 +
.../query/ClusterAggregateExecutorTest.java | 4 +-
.../query/ClusterDataQueryExecutorTest.java | 10 +-
.../cluster/query/ClusterFillExecutorTest.java | 4 +-
.../cluster/query/ClusterPlanExecutorTest.java | 2 +-
.../cluster/query/ClusterQueryRouterTest.java | 12 +-
.../ClusterGroupByNoVFilterDataSetTest.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 2 +-
.../caller/PullMeasurementSchemaHandlerTest.java | 12 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 14 +-
cluster/src/test/resources/logback.xml | 2 +-
.../resources/node1conf/iotdb-cluster.properties | 2 +-
.../resources/node2conf/iotdb-cluster.properties | 2 +-
.../resources/node3conf/iotdb-cluster.properties | 2 +-
...-Languages.md => Programming-Cpp-Native-API.md} | 111 ++--
docs/UserGuide/API/Programming-Go-Native-API.md | 65 ++
docs/UserGuide/API/Programming-JDBC.md | 12 +-
...ative-API.md => Programming-Java-Native-API.md} | 165 ++++--
.../UserGuide/API/Programming-Python-Native-API.md | 100 ++--
docs/UserGuide/API/Programming-TsFile-API.md | 159 ++---
.../{UDF => Advanced-Features}/Triggers.md | 181 +++++-
.../UDF-User-Defined-Function.md | 0
docs/UserGuide/Appendix/SQL-Reference.md | 28 +-
.../Data-Concept/Data-Model-and-Terminology.md | 24 +-
.../DDL-Data-Definition-Language.md | 42 +-
.../DML-Data-Manipulation-Language.md | 11 +-
...-Languages.md => Programming-Cpp-Native-API.md} | 122 +---
docs/zh/UserGuide/API/Programming-Go-Native-API.md | 65 ++
docs/zh/UserGuide/API/Programming-JDBC.md | 16 +-
...ative-API.md => Programming-Java-Native-API.md} | 126 ++--
.../UserGuide/API/Programming-Python-Native-API.md | 220 +++++++
docs/zh/UserGuide/API/Programming-TsFile-API.md | 156 ++---
.../{UDF => Advanced-Features}/Triggers.md | 182 +++++-
.../UDF-User-Defined-Function.md | 0
docs/zh/UserGuide/Appendix/SQL-Reference.md | 28 +-
.../Data-Concept/Data-Model-and-Terminology.md | 24 +-
.../DDL-Data-Definition-Language.md | 39 ++
.../DML-Data-Manipulation-Language.md | 11 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 5 +-
.../org/apache/iotdb/DataMigrationExample.java | 3 +-
.../main/java/org/apache/iotdb/SessionExample.java | 6 +-
.../org/apache/iotdb/VectorSessionExample.java | 337 +++++++++++
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 5 +-
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 3 +-
.../org/apache/iotdb/hive/TsFileTestHelper.java | 3 +-
server/pom.xml | 6 +
.../resources/conf/iotdb-engine.properties | 269 ++++-----
.../org/apache/iotdb/db/concurrent/ThreadName.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 25 +
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 1 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 3 +-
.../db/engine/cache/CacheHitRatioMonitor.java | 28 +
.../engine/cache/CacheHitRatioMonitorMXBean.java | 10 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 5 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 101 +++-
.../iotdb/db/engine/flush/NotifyFlushMemTable.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 190 ++++--
.../apache/iotdb/db/engine/memtable/IMemTable.java | 15 +-
.../db/engine/memtable/IWritableMemChunk.java | 43 +-
.../db/engine/memtable/PrimitiveMemTable.java | 9 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 87 ++-
.../db/engine/merge/manage/MergeResource.java | 12 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 3 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 6 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 5 +-
.../db/engine/querycontext/QueryDataSource.java | 12 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 106 +++-
.../engine/storagegroup/StorageGroupProcessor.java | 37 +-
.../db/engine/storagegroup/TsFileProcessor.java | 164 ++++--
.../db/engine/storagegroup/TsFileResource.java | 141 ++++-
...eption.java => AlignedTimeseriesException.java} | 16 +-
...ption.java => DuplicatedTemplateException.java} | 13 +-
.../metadata/StorageGroupNotSetException.java | 4 +
...eption.java => UndefinedTemplateException.java} | 13 +-
.../apache/iotdb/db/metadata/MLogTxtWriter.java | 36 +-
.../org/apache/iotdb/db/metadata/MManager.java | 626 +++++++++++++++++---
.../java/org/apache/iotdb/db/metadata/MTree.java | 389 ++++++++++--
.../apache/iotdb/db/metadata/MeasurementMeta.java | 14 +-
.../org/apache/iotdb/db/metadata/MetaUtils.java | 24 +
.../iotdb/db/metadata/MetadataOperationType.java | 2 +
.../org/apache/iotdb/db/metadata/PartialPath.java | 6 +-
.../VectorPartialPath.java} | 42 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 38 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 94 +++
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 20 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 26 +-
.../iotdb/db/metadata/template/Template.java | 170 ++++++
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 134 ++++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 7 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 25 +
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 5 +
.../db/qp/physical/crud/CreateTemplatePlan.java | 240 ++++++++
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 5 +
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 99 ++--
.../db/qp/physical/crud/InsertTabletPlan.java | 70 ++-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 5 +
.../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 5 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 14 +
.../db/qp/physical/crud/RawDataQueryPlan.java | 63 +-
.../SetDeviceTemplatePlan.java} | 82 ++-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 5 +
...oupPlan.java => AutoCreateDeviceMNodePlan.java} | 69 +--
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 259 ++++++++
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 7 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 9 +-
...erPlan.java => SetUsingDeviceTemplatePlan.java} | 56 +-
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 36 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 160 +----
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 92 ++-
.../iotdb/db/query/context/QueryContext.java | 4 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 25 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 8 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 143 ++++-
.../iotdb/db/query/executor/QueryRouter.java | 10 +
.../db/query/executor/fill/LastPointReader.java | 34 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 6 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 17 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 15 +-
.../query/reader/series/SeriesAggregateReader.java | 2 +-
.../reader/series/SeriesRawDataBatchReader.java | 4 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 129 ++--
.../reader/series/SeriesReaderByTimestamp.java | 4 +-
.../query/reader/series/SeriesReaderFactory.java | 94 +++
.../db/query/reader/series/VectorSeriesReader.java | 144 +++++
.../query/timegenerator/ServerTimeGenerator.java | 7 +
.../iotdb/db/rescon/PrimitiveArrayManager.java | 7 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 16 +
.../apache/iotdb/db/rescon/TVListAllocator.java | 15 +-
.../org/apache/iotdb/db/service/ServiceType.java | 3 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 148 ++++-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 39 +-
.../org/apache/iotdb/db/tools/mlog/MLogParser.java | 4 +
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 15 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 3 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 36 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 119 ++--
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 27 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 19 +
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 8 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 74 +++
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +
.../iotdb/db/utils/datastructure/TVList.java | 59 +-
.../iotdb/db/utils/datastructure/VectorTVList.java | 653 +++++++++++++++++++++
.../windowing/api/Evaluator.java} | 13 +-
.../windowing/api/Window.java} | 49 +-
.../windowing/configuration/Configuration.java} | 18 +-
.../SlidingSizeWindowConfiguration.java | 61 ++
.../SlidingTimeWindowConfiguration.java | 61 ++
.../windowing/exception/WindowingException.java} | 8 +-
.../SlidingSizeWindowEvaluationHandler.java | 58 ++
.../SlidingTimeWindowEvaluationHandler.java | 78 +++
.../handler/SlidingWindowEvaluationHandler.java | 124 ++++
.../windowing/runtime/WindowEvaluationTask.java} | 32 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 99 ++++
.../utils/windowing/window/EvictableBatchList.java | 173 ++++++
.../db/utils/windowing/window/WindowImpl.java | 204 +++++++
.../iotdb/db/writelog/recover/LogReplayer.java | 27 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 57 ++
.../db/engine/memtable/MemTableTestUtils.java | 81 ++-
.../db/engine/memtable/MemtableBenchmark.java | 1 -
.../db/engine/memtable/PrimitiveMemTableTest.java | 130 +++-
.../db/engine/modification/DeletionQueryTest.java | 10 +-
.../storagegroup/StorageGroupProcessorTest.java | 28 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 6 +-
.../engine/storagegroup/TsFileProcessorTest.java | 72 ++-
.../iotdb/db/integration/IOTDBGroupByIT.java | 19 +
.../db/integration/IOTDBInsertAlignedValuesIT.java | 149 +++++
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 2 +-
.../iotdb/db/integration/IoTDBCompressTypeIT.java | 5 -
.../iotdb/db/integration/IoTDBDeletionIT.java | 12 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 6 +-
.../db/integration/IoTDBFlushQueryMergeIT.java | 4 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 97 ++-
.../db/integration/IoTDBSequenceDataQueryIT.java | 6 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 8 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 4 +
.../apache/iotdb/db/integration/IoTDBTagIT.java | 40 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +-
.../aggregation/IoTDBAggregationByLevelIT.java | 21 +
.../iotdb/db/metadata/MManagerBasicTest.java | 535 ++++++++++++++++-
.../iotdb/db/metadata/MManagerImproveTest.java | 17 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 246 ++++++++
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 264 +++++++++
.../db/qp/physical/PhysicalPlanSerializeTest.java | 44 ++
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 15 +
.../reader/series/SeriesAggregateReaderTest.java | 6 +-
.../reader/series/SeriesReaderByTimestampTest.java | 6 +-
.../query/reader/series/SeriesReaderTestUtil.java | 3 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 2 +-
.../db/utils/datastructure/VectorTVListTest.java | 143 +++++
.../SlidingSizeWindowEvaluationHandlerTest.java | 184 ++++++
.../SlidingTimeWindowEvaluationHandlerTest.java | 226 +++++++
.../iotdb/db/writelog/recover/LogReplayerTest.java | 22 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 3 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 5 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../java/org/apache/iotdb/session/Session.java | 174 +++++-
.../apache/iotdb/session/SessionConnection.java | 60 ++
.../org/apache/iotdb/session/SessionUtils.java | 133 +++--
.../iotdb/session/IoTDBSessionComplexIT.java | 7 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 57 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 5 +-
.../java/org/apache/iotdb/session/SessionUT.java | 52 +-
site/src/main/.vuepress/config.js | 74 +--
.../iotdb/spark/tsfile/NarrowConverter.scala | 4 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 5 +-
thrift/src/main/thrift/rpc.thrift | 31 +
.../iotdb/tsfile/encoding/decoder/Decoder.java | 4 +
.../iotdb/tsfile/file/header/ChunkHeader.java | 15 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 22 +-
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 74 +++
.../metadata/ITimeSeriesMetadata.java} | 23 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 23 +-
.../tsfile/file/metadata/VectorChunkMetadata.java | 178 ++++++
.../file/metadata/VectorTimeSeriesMetadata.java | 97 +++
.../tsfile/file/metadata/enums/TSDataType.java | 8 +-
.../file/metadata/statistics/Statistics.java | 96 +--
.../file/metadata/statistics/TimeStatistics.java | 161 +++++
.../iotdb/tsfile/read/TsFileSequenceReader.java | 38 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 60 ++
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 5 +-
.../read/controller/IChunkMetadataLoader.java | 8 +-
.../tsfile/read/controller/IMetadataQuerier.java | 6 +-
.../read/controller/MetadataQuerierByFileImpl.java | 13 +-
.../expression/impl/SingleSeriesExpression.java | 4 +
.../iotdb/tsfile/read/filter/ValueFilter.java | 106 ++++
.../iotdb/tsfile/read/filter/operator/In.java | 6 +-
.../query/executor/ExecutorWithTimeGenerator.java | 4 +-
.../tsfile/read/query/executor/TsFileExecutor.java | 4 +-
.../query/timegenerator/TsFileTimeGenerator.java | 4 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 8 +-
.../read/reader/chunk/VectorChunkReader.java | 262 +++++++++
.../tsfile/read/reader/page/TimePageReader.java | 92 +++
.../page/{PageReader.java => ValuePageReader.java} | 149 +++--
.../reader/page/VectorChunkReader.java} | 4 +-
.../tsfile/read/reader/page/VectorPageReader.java | 122 ++++
.../reader/series/AbstractFileSeriesReader.java | 14 +-
.../read/reader/series/EmptyFileSeriesReader.java | 6 +-
.../read/reader/series/FileSeriesReader.java | 9 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 13 +-
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 2 +
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 121 ++++
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 4 +
.../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 88 +++
.../apache/iotdb/tsfile/write/TsFileWriter.java | 13 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 6 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 32 +-
.../tsfile/write/chunk/IChunkGroupWriter.java | 4 +-
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 15 +-
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 255 ++++++++
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 252 ++++++++
.../tsfile/write/chunk/VectorChunkWriterImpl.java | 202 +++++++
.../apache/iotdb/tsfile/write/page/PageWriter.java | 6 +-
.../iotdb/tsfile/write/page/TimePageWriter.java | 177 ++++++
.../page/{PageWriter.java => ValuePageWriter.java} | 160 ++---
.../apache/iotdb/tsfile/write/record/Tablet.java | 251 +++++---
.../write/record/datapoint/BooleanDataPoint.java | 2 +-
.../write/record/datapoint/DoubleDataPoint.java | 2 +-
.../write/record/datapoint/FloatDataPoint.java | 2 +-
.../write/record/datapoint/IntDataPoint.java | 2 +-
.../write/record/datapoint/LongDataPoint.java | 2 +-
.../write/record/datapoint/StringDataPoint.java | 2 +-
.../tsfile/write/schema/IMeasurementSchema.java | 77 +++
.../tsfile/write/schema/MeasurementSchema.java | 89 ++-
.../apache/iotdb/tsfile/write/schema/Schema.java | 25 +-
.../write/schema/VectorMeasurementSchema.java | 370 ++++++++++++
.../write/writer/RestorableTsFileIOWriter.java | 17 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 39 +-
...easurementChunkMetadataListMapIteratorTest.java | 13 +-
.../tsfile/read/controller/ChunkLoaderTest.java | 7 +-
.../query/timegenerator/ReaderByTimestampTest.java | 4 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 6 +-
.../org/apache/iotdb/tsfile/utils/BitMapTest.java | 67 +++
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 4 +-
.../tsfile/write/DefaultDeviceTemplateTest.java | 5 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 3 +-
.../write/schema/converter/SchemaBuilderTest.java | 17 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 5 +-
.../tsfile/write/writer/TestTsFileOutput.java | 48 +-
.../tsfile/write/writer/TimeChunkWriterTest.java | 111 ++++
.../tsfile/write/writer/TimePageWriterTest.java | 171 ++++++
.../tsfile/write/writer/ValueChunkWriterTest.java | 109 ++++
.../tsfile/write/writer/ValuePageWriterTest.java | 291 +++++++++
.../write/writer/VectorChunkWriterImplTest.java | 178 ++++++
.../write/writer/VectorMeasurementSchemaStub.java | 128 ++++
322 files changed, 15716 insertions(+), 2646 deletions(-)
rename docs/UserGuide/API/{Programming-Other-Languages.md =>
Programming-Cpp-Native-API.md} (83%)
create mode 100644 docs/UserGuide/API/Programming-Go-Native-API.md
rename docs/UserGuide/API/{Programming-Native-API.md =>
Programming-Java-Native-API.md} (80%)
copy client-py/README.md =>
docs/UserGuide/API/Programming-Python-Native-API.md (67%)
rename docs/UserGuide/{UDF => Advanced-Features}/Triggers.md (66%)
rename docs/UserGuide/{UDF => Advanced-Features}/UDF-User-Defined-Function.md
(100%)
rename docs/zh/UserGuide/API/{Programming-Other-Languages.md =>
Programming-Cpp-Native-API.md} (78%)
create mode 100644 docs/zh/UserGuide/API/Programming-Go-Native-API.md
rename docs/zh/UserGuide/API/{Programming-Native-API.md =>
Programming-Java-Native-API.md} (75%)
create mode 100644 docs/zh/UserGuide/API/Programming-Python-Native-API.md
rename docs/zh/UserGuide/{UDF => Advanced-Features}/Triggers.md (68%)
rename docs/zh/UserGuide/{UDF =>
Advanced-Features}/UDF-User-Defined-Function.md (100%)
create mode 100644
example/session/src/main/java/org/apache/iotdb/VectorSessionExample.java
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{PathAlreadyExistException.java
=> AlignedTimeseriesException.java} (72%)
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{IllegalParameterOfPathException.java
=> DuplicatedTemplateException.java} (73%)
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{IllegalParameterOfPathException.java
=> UndefinedTemplateException.java} (73%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/cache/AccountableString.java
=> metadata/VectorPartialPath.java} (50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/Template.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/CreateTemplatePlan.java
copy server/src/main/java/org/apache/iotdb/db/qp/physical/{sys/SetTTLPlan.java
=> crud/SetDeviceTemplatePlan.java} (50%)
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{SetStorageGroupPlan.java
=> AutoCreateDeviceMNodePlan.java} (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{StopTriggerPlan.java
=> SetUsingDeviceTemplatePlan.java} (53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReaderFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/VectorSeriesReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/datastructure/VectorTVList.java
copy server/src/main/java/org/apache/iotdb/db/{service/IoTDBMBean.java =>
utils/windowing/api/Evaluator.java} (76%)
copy
server/src/main/java/org/apache/iotdb/db/{query/udf/core/reader/LayerPointReader.java
=> utils/windowing/api/Window.java} (57%)
copy
server/src/main/java/org/apache/iotdb/db/{query/dataset/UDFInputDataSet.java =>
utils/windowing/configuration/Configuration.java} (68%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/configuration/SlidingSizeWindowConfiguration.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/configuration/SlidingTimeWindowConfiguration.java
copy
server/src/main/java/org/apache/iotdb/db/{query/udf/api/exception/UDFException.java
=> utils/windowing/exception/WindowingException.java} (80%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/handler/SlidingSizeWindowEvaluationHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/handler/SlidingTimeWindowEvaluationHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/handler/SlidingWindowEvaluationHandler.java
copy
server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/DropFunctionPlan.java
=> utils/windowing/runtime/WindowEvaluationTask.java} (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/runtime/WindowEvaluationTaskPoolManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/window/EvictableBatchList.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/windowing/window/WindowImpl.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IOTDBInsertAlignedValuesIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/qp/physical/InsertRowPlanTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/VectorTVListTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/windowing/SlidingSizeWindowEvaluationHandlerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/windowing/SlidingTimeWindowEvaluationHandlerTest.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/IChunkMetadata.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/{read/reader/IPageReader.java =>
file/metadata/ITimeSeriesMetadata.java} (70%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/VectorChunkMetadata.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/VectorTimeSeriesMetadata.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/statistics/TimeStatistics.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/VectorChunkReader.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/TimePageReader.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/{PageReader.java
=> ValuePageReader.java} (59%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/{write/writer/IDataWriter.java =>
read/reader/page/VectorChunkReader.java} (90%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/VectorPageReader.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitMap.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/TimeChunkWriter.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ValueChunkWriter.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/VectorChunkWriterImpl.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/TimePageWriter.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/{PageWriter.java
=> ValuePageWriter.java} (69%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/IMeasurementSchema.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/VectorMeasurementSchema.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/utils/BitMapTest.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultEmptyReader.java
=>
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TestTsFileOutput.java
(51%)
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TimeChunkWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TimePageWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/ValueChunkWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/ValuePageWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/VectorChunkWriterImplTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/VectorMeasurementSchemaStub.java
