This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch new_mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
discard a1e83fa Fragment schedule develop
discard a15776f [To_new_mpp] add IDataBlockManager (#5240)
omit b3e564a [To_new_mpp] add common classes & thrift files (#5239)
omit 7c04879 [To_new_mpp] Basic query memory control (#5216)
omit 37f6f70 Basic implementation of FragmentInstanceManager
add 08e9d34 change master version to 0.14.0-SNAPSHOT (#5209)
add c3e49a8 [IOTDB-2735] Remove the redundant code in Tablet (#5211)
add b05a81f [IOTDB-2732] Reject inserting an invalid infinity float value
(#5210)
add 10b15ea [IOTDB-2734] Correct result type name in ResultMetadata
(#5213)
add 2a5d371 Update dependabot to check rel/0.13 (#5203)
add 83ab2f6 Fix .github/dependabot.yml (#5222)
add 272d5db Update UserGuide descriptions (#5219)
add 1460bb7 [IOTDB-2739] Update v0.13 upgrade user guide (#5234)
add 0d2cad6 Bump org.slf4j.version from 1.7.32 to 1.7.36 (#5225)
add 7ce67a1 [IOTDB-2742] Hide IDTable configurations (#5238)
add b3147de fix write with null value in tsFileWriter (#5237)
add 30cd1c0 Revert "fix write with null value in tsFileWriter (#5237)"
(#5246)
add a88b6b5 Modify cross priority param to upper case in doc (#5242)
add c3d34b6 [IOTDB-2590] Group by time query: support time sliding step
less than the time interval (#5196)
add c2a2acd [IOTDB-2736] DELETE_STORAGE_GROUP can not be granted to user
(reporting 401) (#5233)
add 9f04de9 [IOTDB-2723] Fix sequence inner space compaction lose data
add 2f78450 [IOTDB-2614]Fix inserting tablet with null value in
TsFileWriter (#5244)
add 919532a Bump jacoco-maven-plugin from 0.8.5 to 0.8.7 (#5194)
add 74189ee Bump maven-bundle-plugin from 5.1.1 to 5.1.4 (#5192)
add 6347db7 [IOTDB-2725] MPP query engine interface definition (#5250)
add 1ff6db9 [IOTDB-2524] Aligned Timeseries support tags and attributes
(#5191)
add 5a88650 [IOTDB-2685] Create and start config node (#5247)
add 5edf9e9 [IOTDB-2750] Enhance check statement before writing mlog
(#5253)
add 34b480d [IOTDB-2737] Fix ID Table compaction bug (#5214)
add 0426e72 [IOTDB-1593] Fix generated files in client-py have unapproved
license (#5258)
add 37dae90 add setNoMoreTsBlocks(), close() and abort() methods in
SinkHandle interface (#5256)
add d29ef70 [IOTDB-2749]Fix isPathExist check on MTree (#5260)
new 678f712 Basic implementation of FragmentInstanceManager
new d31733f [To_new_mpp] Basic query memory control (#5216)
new 4a85d31 [To_new_mpp] add common classes & thrift files (#5239)
new 6e4e2cb [To_new_mpp] add IDataBlockManager (#5240)
new 0ef2b42 Fragment schedule develop
new 1feea78 Sync with master
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (a1e83fa)
\
N -- N -- N refs/heads/new_mpp (1feea78)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/dependabot.yml | 26 +
README.md | 4 +-
README_ZH.md | 4 +-
antlr/pom.xml | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 7 +-
cli/pom.xml | 2 +-
client-cpp/pom.xml | 2 +-
client-py/pom.xml | 2 +-
cluster/pom.xml | 2 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 9 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 4 +-
.../groupby/ClusterGroupByNoVFilterDataSet.java | 4 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 2 +-
.../query/groupby/MergeGroupByExecutor.java | 2 +-
.../query/groupby/RemoteGroupByExecutor.java | 2 +-
.../cluster/query/manage/ClusterQueryManager.java | 2 +-
.../cluster/query/reader/ClusterReaderFactory.java | 2 +-
.../iotdb/cluster/query/reader/EmptyReader.java | 2 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 2 +-
code-coverage/pom.xml | 4 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 19 +-
.../src/assembly/resources/conf/confignode-env.bat | 146 +++++
.../src/assembly/resources/conf/confignode-env.sh | 264 +++++++++
.../resources/conf/iotdb-confignode.properties | 10 +-
.../src/assembly/resources/conf/jmx.access | 0
.../src/assembly/resources/conf/jmx.password | 0
.../assembly/resources/sbin/start-confignode.bat | 122 ++++
.../assembly/resources/sbin/start-confignode.sh | 77 +++
.../assembly/resources/sbin/stop-confignode.bat | 38 ++
.../resources/sbin/stop-confignode.sh} | 32 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 5 +-
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 136 +++++
.../iotdb/confignode/conf/ConfigNodeConstant.java | 28 +-
.../confignode/conf/ConfigNodeDescriptor.java | 66 ++-
.../confignode/exception/ConfigNodeException.java | 11 +-
.../conf/RepeatConfigurationException.java} | 18 +-
.../startup/StartupException.java} | 17 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 125 ++++
.../iotdb/confignode/service/ConfigNodeMBean.java | 7 +-
.../confignode/service/register/IService.java | 40 +-
.../confignode/service/register/JMXService.java | 105 ++++
.../service/register/RegisterManager.java | 82 +++
.../register/ServiceType.java} | 30 +-
.../confignode/service/startup/StartupCheck.java | 11 +-
.../confignode/service/startup/StartupChecks.java | 89 +++
.../{impl => server}/ConfigNodeRPCServer.java | 2 +-
.../confignode/conf/ConfigNodeDescriptorTest.java | 76 ---
.../manager/hash/DeviceGroupHashExecutorTest.java | 3 +-
.../utils/ConfigNodeEnvironmentUtils.java | 133 +++++
consensus/pom.xml | 2 +-
cross-tests/pom.xml | 2 +-
distribution/pom.xml | 2 +-
docs/Download/README.md | 16 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 4 +-
docs/UserGuide/API/Programming-TsFile-API.md | 4 +-
.../Administration-Management/Administration.md | 6 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 39 +-
docs/UserGuide/Process-Data/Triggers.md | 6 +-
.../Process-Data/UDF-User-Defined-Function.md | 8 +-
docs/UserGuide/Query-Data/Aggregate-Query.md | 28 +-
docs/UserGuide/Query-Data/Overview.md | 2 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
docs/UserGuide/Reference/Config-Manual.md | 7 +-
docs/UserGuide/Reference/SQL-Reference.md | 2 +-
docs/zh/Download/README.md | 11 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 4 +-
docs/zh/UserGuide/API/Programming-TsFile-API.md | 4 +-
.../Administration-Management/Administration.md | 8 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 34 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 6 +-
.../Process-Data/UDF-User-Defined-Function.md | 8 +-
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 37 +-
docs/zh/UserGuide/Query-Data/Overview.md | 2 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
docs/zh/UserGuide/Reference/Config-Manual.md | 5 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 2 +-
example/client-cpp-example/pom.xml | 2 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 4 +-
example/kafka/readme.md | 4 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rabbitmq/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 4 +-
example/session/pom.xml | 2 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 9 +-
.../main/java/org/apache/iotdb/SessionExample.java | 5 +-
example/trigger/pom.xml | 4 +-
example/tsfile/pom.xml | 2 +-
example/tsfile/readme.md | 2 +-
example/udf/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 2 +-
grafana-plugin/pom.xml | 2 +-
hadoop/README.md | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 2 +-
integration/pom.xml | 2 +-
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 26 +
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 49 ++
.../integration/IoTDBCompactionWithIDTableIT.java | 352 ++++++++++++
.../db/integration/IoTDBResultMetadataIT.java | 82 +++
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 14 -
...roupBySlidingWindowQueryWithValueFilterIT.java} | 575 +++++++------------
...pBySlidingWindowQueryWithoutValueFilterIT.java} | 552 ++++++------------
.../integration/{ => groupby}/IOTDBGroupByIT.java | 2 +-
.../{ => groupby}/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByFillIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByFillMixPathsIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByFillWithRangeIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByMonthFillIT.java | 2 +-
.../{ => groupby}/IoTDBGroupByMonthIT.java | 95 ++-
.../{ => groupby}/IoTDBGroupByUnseqIT.java | 2 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 5 +-
{example/mqtt => iotdb-commons}/pom.xml | 15 +-
.../apache/iotdb/commons}/hash/APHashExecutor.java | 2 +-
.../iotdb/commons}/hash/BKDRHashExecutor.java | 2 +-
.../commons}/hash/DeviceGroupHashExecutor.java | 2 +-
.../apache/iotdb/commons}/hash/JSHashExecutor.java | 2 +-
.../iotdb/commons}/hash/SDBMHashExecutor.java | 2 +-
jdbc/README.md | 4 +-
jdbc/pom.xml | 2 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 29 +-
library-udf/pom.xml | 2 +-
metrics/dropwizard-metrics/pom.xml | 4 +-
metrics/interface/pom.xml | 4 +-
metrics/micrometer-metrics/pom.xml | 4 +-
metrics/pom.xml | 2 +-
openapi/pom.xml | 2 +-
pom.xml | 16 +-
server/pom.xml | 11 +-
.../resources/conf/iotdb-engine.properties | 21 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 38 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 20 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 26 +-
.../db/engine/compaction/CompactionUtils.java | 19 +-
.../manage/CrossSpaceCompactionResource.java | 6 -
.../inner/utils/InnerSpaceCompactionUtils.java | 8 +-
.../utils/SingleSeriesCompactionExecutor.java | 9 +-
.../org/apache/iotdb/db/metadata/MManager.java | 45 +-
.../idtable/AppendOnlyDiskSchemaManager.java | 39 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 10 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 28 +
.../iotdb/db/metadata/idtable/IDTableManager.java | 21 +
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 8 +-
.../mpp/buffer}/IDataBlockManager.java | 6 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 56 ++
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 22 +-
.../mpp/common/Analysis.java} | 8 +-
.../mpp/common/FillPolicy.java} | 9 +-
.../mpp/common/GroupByTimeParameter.java} | 13 +-
.../mpp/common/OrderBy.java} | 16 +-
.../mpp/common/QueryContext.java} | 18 +-
.../mpp/common/QueryId.java} | 16 +-
.../mpp/common/QuerySession.java} | 7 +-
.../mpp/common/TreeNode.java} | 32 +-
.../ITSBlock.java => db/mpp/common/TsBlock.java} | 15 +-
.../iotdb/db/mpp/common/TsBlockMetadata.java | 41 ++
.../mpp/common/WithoutPolicy.java} | 10 +-
.../execution/Coordinator.java} | 32 +-
.../db/mpp/execution/ExecFragmentInstance.java | 57 ++
.../iotdb/db/mpp/execution/QueryExecution.java | 96 ++++
.../iotdb/db/mpp/execution/QueryScheduler.java | 51 ++
.../mpp/execution/QueryStateMachine.java} | 11 +-
.../{ => db}/mpp/memory/LocalMemoryManager.java | 2 +-
.../iotdb/{ => db}/mpp/memory/MemoryPool.java | 2 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 49 ++
.../iotdb/db/mpp/operator/OperatorContext.java | 25 +-
.../iotdb/db/mpp/operator/SeriesScanOperator.java | 21 +-
.../iotdb/db/mpp/plan/DistributedQueryPlan.java | 20 +-
.../iotdb/db/mpp/plan/DistributionPlanner.java | 21 +-
.../apache/iotdb/db/mpp/plan/FragmentInstance.java | 17 +-
.../mpp/plan/FragmentInstanceId.java} | 15 +-
.../apache/iotdb/db/mpp/plan/LogicalPlanner.java | 35 +-
.../apache/iotdb/db/mpp/plan/LogicalQueryPlan.java | 22 +-
.../org/apache/iotdb/db/mpp/plan/PlanFragment.java | 19 +-
.../mpp/plan/PlanFragmentId.java} | 11 +-
.../apache/iotdb/db/mpp/plan/node/PlanNode.java | 22 +-
.../apache/iotdb/db/mpp/plan/node/PlanNodeId.java | 34 ++
.../mpp/plan/node/PlanNodeIdAllocator.java} | 8 +-
.../db/mpp/plan/node/process/DeviceMergeNode.java | 66 +++
.../iotdb/db/mpp/plan/node/process/FillNode.java | 30 +-
.../iotdb/db/mpp/plan/node/process/FilterNode.java | 30 +-
.../db/mpp/plan/node/process/FilterNullNode.java | 30 +-
.../db/mpp/plan/node/process/GroupByLevelNode.java | 41 ++
.../iotdb/db/mpp/plan/node/process/LimitNode.java | 23 +-
.../mpp/plan/node/process/OffsetNode.java} | 31 +-
.../db/mpp/plan/node/process/ProcessNode.java | 17 +-
.../node/process/RowBasedSeriesAggregateNode.java | 59 ++
.../iotdb/db/mpp/plan/node/process/SortNode.java | 32 +-
.../db/mpp/plan/node/process/TimeJoinNode.java | 67 +++
.../iotdb/db/mpp/plan/node/sink/CsvSinkNode.java | 15 +-
.../db/mpp/plan/node/sink/FragmentSinkNode.java | 17 +-
.../iotdb/db/mpp/plan/node/sink/SinkNode.java | 16 +-
.../db/mpp/plan/node/sink/ThriftSinkNode.java | 17 +-
.../db/mpp/plan/node/source/CsvSourceNode.java | 17 +-
.../mpp/plan/node/source/SeriesAggregateNode.java | 81 +++
.../db/mpp/plan/node/source/SeriesScanNode.java | 85 +++
.../iotdb/db/mpp/plan/node/source/SourceNode.java | 16 +-
.../mpp/plan/optimzation/PlanOptimizer.java} | 14 +-
.../mpp/schedule}/ExecutionContext.java | 4 +-
.../mpp/schedule}/FragmentInstanceManager.java | 14 +-
.../schedule}/FragmentInstanceTaskCallback.java | 4 +-
.../schedule}/FragmentInstanceTaskExecutor.java | 6 +-
.../schedule}/FragmentInstanceTimeoutSentinel.java | 8 +-
.../mpp/schedule}/IFragmentInstanceManager.java | 11 +-
.../execution => db/mpp/schedule}/queue/ID.java | 2 +-
.../mpp/schedule}/queue/IDIndexedAccessible.java | 2 +-
.../mpp/schedule}/queue/IndexedBlockingQueue.java | 2 +-
.../mpp/schedule}/queue/L1PriorityQueue.java | 2 +-
.../mpp/schedule}/queue/L2PriorityQueue.java | 2 +-
.../mpp/schedule}/task/FragmentInstanceID.java | 4 +-
.../mpp/schedule}/task/FragmentInstanceTask.java | 10 +-
.../schedule}/task/FragmentInstanceTaskStatus.java | 2 +-
.../sys/CreateAlignedTimeSeriesOperator.java | 55 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 2 +-
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 7 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 125 +++-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 12 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 22 +
.../db/query/aggregation/AggregateResult.java | 53 +-
.../aggregation/RemovableAggregateResult.java} | 13 +-
.../db/query/aggregation/impl/AvgAggrResult.java | 22 +-
.../db/query/aggregation/impl/CountAggrResult.java | 14 +-
.../query/aggregation/impl/ExtremeAggrResult.java | 8 +-
.../aggregation/impl/FirstValueAggrResult.java | 3 -
.../aggregation/impl/LastValueAggrResult.java | 3 -
.../query/aggregation/impl/MaxTimeAggrResult.java | 5 +
.../query/aggregation/impl/MaxValueAggrResult.java | 4 +
.../query/aggregation/impl/MinTimeAggrResult.java | 5 +
.../query/aggregation/impl/MinValueAggrResult.java | 4 +
.../db/query/aggregation/impl/SumAggrResult.java | 20 +-
.../dataset/groupby/GroupByEngineDataSet.java | 239 --------
.../query/dataset/groupby/GroupByFillDataSet.java | 2 +-
.../query/dataset/groupby/GroupByLevelDataSet.java | 2 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 177 ++++++
.../dataset/groupby/GroupByTimeEngineDataSet.java | 91 +++
.../groupby/GroupByWithValueFilterDataSet.java | 85 +--
.../groupby/GroupByWithoutValueFilterDataSet.java | 104 ++--
.../iotdb/db/query/executor/QueryRouter.java | 10 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 13 +-
.../groupby/AlignedGroupByExecutor.java | 2 +-
.../groupby/GroupByExecutor.java | 2 +-
.../groupby/SlidingWindowGroupByExecutor.java | 66 +++
.../SlidingWindowGroupByExecutorFactory.java | 117 ++++
.../EmptyQueueSlidingWindowGroupByExecutor.java | 51 ++
.../groupby/impl}/LocalAlignedGroupByExecutor.java | 3 +-
.../groupby/impl}/LocalGroupByExecutor.java | 3 +-
...MonotonicQueueSlidingWindowGroupByExecutor.java | 73 +++
.../NormalQueueSlidingWindowGroupByExecutor.java | 61 ++
.../SmoothQueueSlidingWindowGroupByExecutor.java | 55 ++
.../db/query/factory/AggregateResultFactory.java | 2 +
.../db/service/thrift/impl/TSServiceImpl.java | 4 +-
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 2 +
.../org/apache/iotdb/db/utils/CommonUtils.java | 12 +-
.../iotdb/db/utils/datastructure/TimeSelector.java | 18 +
.../timerangeiterator/AggrWindowIterator.java | 149 +++++
.../timerangeiterator/ITimeRangeIterator.java | 27 +-
.../timerangeiterator/PreAggrWindowIterator.java | 142 +++++
.../PreAggrWindowWithNaturalMonthIterator.java | 109 ++++
.../TimeRangeIteratorFactory.java | 69 +++
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 83 ++-
.../iotdb/db/metadata/MManagerBasicTest.java | 30 +
.../iotdb/db/metadata/idtable/IDTableTest.java | 4 +
.../iotdb/{ => db}/mpp/memory/MemoryPoolTest.java | 2 +-
.../mpp/schedule}/queue/L1PriorityQueueTest.java | 2 +-
.../mpp/schedule}/queue/L2PriorityQueueTest.java | 2 +-
.../mpp/schedule}/queue/QueueElement.java | 2 +-
.../db/qp/physical/PhysicalPlanSerializeTest.java | 2 +
...imeDataSetTest.java => GroupByDataSetTest.java} | 4 +-
.../dataset/groupby/GroupByEngineDataSetTest.java | 504 ----------------
.../dataset/groupby/GroupByTimeDataSetTest.java | 636 +++++++++++++++------
.../iotdb/db/utils/TimeRangeIteratorTest.java | 220 +++++++
.../db/utils/datastructure/TimeSelectorTest.java | 22 +
service-rpc/pom.xml | 2 +-
session/pom.xml | 2 +-
.../java/org/apache/iotdb/session/Session.java | 19 +-
.../session/IoTDBSessionDisableMemControlIT.java | 9 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 2 +-
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 2 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 9 +-
site/pom.xml | 2 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
thrift-cluster/pom.xml | 2 +-
thrift-confignode/pom.xml | 2 +-
thrift-influxdb/pom.xml | 2 +-
thrift-sync/pom.xml | 2 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/rpc.thrift | 2 +
tsfile/README.md | 2 +-
tsfile/pom.xml | 2 +-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 9 +-
.../chunk/NonAlignedChunkGroupWriterImpl.java | 6 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 12 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 15 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 99 ++++
zeppelin-interpreter/pom.xml | 2 +-
319 files changed, 6956 insertions(+), 2780 deletions(-)
create mode 100644 confignode/src/assembly/resources/conf/confignode-env.bat
create mode 100644 confignode/src/assembly/resources/conf/confignode-env.sh
copy {server => confignode}/src/assembly/resources/conf/jmx.access (100%)
copy {server => confignode}/src/assembly/resources/conf/jmx.password (100%)
create mode 100644 confignode/src/assembly/resources/sbin/start-confignode.bat
create mode 100644 confignode/src/assembly/resources/sbin/start-confignode.sh
create mode 100644 confignode/src/assembly/resources/sbin/stop-confignode.bat
rename confignode/src/{test/resources/iotdb-confignode.properties =>
assembly/resources/sbin/stop-confignode.sh} (50%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfCheck.java
copy
server/src/main/java/org/apache/iotdb/mpp/execution/queue/IDIndexedAccessible.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/exception/ConfigNodeException.java
(81%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{conf/ConfigNodeConstant.java
=> exception/conf/RepeatConfigurationException.java} (60%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{conf/ConfigNodeConstant.java
=> exception/startup/StartupException.java} (64%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
copy server/src/main/java/org/apache/iotdb/mpp/common/TsBlockMetadata.java =>
confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNodeMBean.java
(87%)
copy server/src/main/java/org/apache/iotdb/mpp/common/ITSBlock.java =>
confignode/src/main/java/org/apache/iotdb/confignode/service/register/IService.java
(51%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/register/JMXService.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/register/RegisterManager.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/{manager/hash/BKDRHashExecutor.java
=> service/register/ServiceType.java} (57%)
copy
server/src/main/java/org/apache/iotdb/mpp/execution/FragmentInstanceTaskCallback.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/service/startup/StartupCheck.java
(74%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/startup/StartupChecks.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/{impl =>
server}/ConfigNodeRPCServer.java (97%)
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptorTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/utils/ConfigNodeEnvironmentUtils.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionWithIDTableIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBResultMetadataIT.java
copy
integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBGroupByQueryWithoutValueFilterIT.java
=> IoTDBGroupBySlidingWindowQueryWithValueFilterIT.java} (61%)
copy
integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBGroupByQueryWithoutValueFilterIT.java
=> IoTDBGroupBySlidingWindowQueryWithoutValueFilterIT.java} (63%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IOTDBGroupByIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IOTDBGroupByInnerIntervalIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByFillIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByFillMixPathsIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByFillWithRangeIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByMonthFillIT.java (99%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByMonthIT.java (75%)
rename integration/src/test/java/org/apache/iotdb/db/integration/{ =>
groupby}/IoTDBGroupByUnseqIT.java (99%)
copy {example/mqtt => iotdb-commons}/pom.xml (76%)
copy {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/APHashExecutor.java
(96%)
copy {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/BKDRHashExecutor.java
(96%)
rename {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/DeviceGroupHashExecutor.java
(95%)
copy {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/JSHashExecutor.java
(96%)
rename {confignode/src/main/java/org/apache/iotdb/confignode/manager =>
iotdb-commons/src/main/java/org/apache/iotdb/commons}/hash/SDBMHashExecutor.java
(96%)
rename server/src/main/java/org/apache/iotdb/{mpp/shuffle =>
db/mpp/buffer}/IDataBlockManager.java (94%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/SinkHandle.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/buffer/SourceHandle.java (67%)
copy server/src/main/java/org/apache/iotdb/{mpp/common/TsBlockMetadata.java =>
db/mpp/common/Analysis.java} (77%)
copy server/src/main/java/org/apache/iotdb/{mpp/common/TsBlockMetadata.java =>
db/mpp/common/FillPolicy.java} (85%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/ExecutionContext.java =>
db/mpp/common/GroupByTimeParameter.java} (66%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/queue/IDIndexedAccessible.java
=> db/mpp/common/OrderBy.java} (75%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/queue/IDIndexedAccessible.java
=> db/mpp/common/QueryContext.java} (69%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/queue/IDIndexedAccessible.java
=> db/mpp/common/QueryId.java} (76%)
copy server/src/main/java/org/apache/iotdb/{mpp/common/TsBlockMetadata.java =>
db/mpp/common/QuerySession.java} (86%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/task/FragmentInstanceTaskStatus.java
=> db/mpp/common/TreeNode.java} (60%)
rename server/src/main/java/org/apache/iotdb/{mpp/common/ITSBlock.java =>
db/mpp/common/TsBlock.java} (70%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/TsBlockMetadata.java
copy server/src/main/java/org/apache/iotdb/{mpp/common/TsBlockMetadata.java =>
db/mpp/common/WithoutPolicy.java} (83%)
copy
server/src/main/java/org/apache/iotdb/db/{query/dataset/groupby/AlignedGroupByExecutor.java
=> mpp/execution/Coordinator.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/ExecFragmentInstance.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryScheduler.java
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/ExecutionContext.java =>
db/mpp/execution/QueryStateMachine.java} (76%)
rename server/src/main/java/org/apache/iotdb/{ =>
db}/mpp/memory/LocalMemoryManager.java (97%)
rename server/src/main/java/org/apache/iotdb/{ =>
db}/mpp/memory/MemoryPool.java (98%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/Operator.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/operator/OperatorContext.java
(57%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/operator/SeriesScanOperator.java
(70%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/DistributedQueryPlan.java
(59%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/DistributionPlanner.java
(62%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/FragmentInstance.java
(65%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/queue/IDIndexedAccessible.java
=> db/mpp/plan/FragmentInstanceId.java} (70%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/APHashExecutor.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/LogicalPlanner.java (54%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/LogicalQueryPlan.java
(62%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/PlanFragment.java (64%)
copy server/src/main/java/org/apache/iotdb/{mpp/common/TsBlockMetadata.java =>
db/mpp/plan/PlanFragmentId.java} (79%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/node/PlanNode.java (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/PlanNodeId.java
rename server/src/main/java/org/apache/iotdb/{mpp/common/TsBlockMetadata.java
=> db/mpp/plan/node/PlanNodeIdAllocator.java} (81%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/DeviceMergeNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/FillNode.java
(58%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/BKDRHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/FilterNode.java
(58%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/FilterNullNode.java
(55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/GroupByLevelNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/LimitNode.java
(61%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/task/FragmentInstanceTaskStatus.java
=> db/mpp/plan/node/process/OffsetNode.java} (60%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/ProcessNode.java
(68%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/RowBasedSeriesAggregateNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/SortNode.java
(56%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/process/TimeJoinNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/CsvSinkNode.java
(74%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/FragmentSinkNode.java
(68%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=> server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/SinkNode.java
(69%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/sink/ThriftSinkNode.java
(70%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/CsvSourceNode.java
(69%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/SeriesAggregateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/SeriesScanNode.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/node/source/SourceNode.java
(67%)
copy
server/src/main/java/org/apache/iotdb/{mpp/execution/queue/IDIndexedAccessible.java
=> db/mpp/plan/optimzation/PlanOptimizer.java} (67%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/ExecutionContext.java (89%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/FragmentInstanceManager.java (92%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/FragmentInstanceTaskCallback.java (90%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/FragmentInstanceTaskExecutor.java (90%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/FragmentInstanceTimeoutSentinel.java (91%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/IFragmentInstanceManager.java (80%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/ID.java (94%)
copy server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/IDIndexedAccessible.java (95%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/IndexedBlockingQueue.java (99%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/L1PriorityQueue.java (98%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/L2PriorityQueue.java (98%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/task/FragmentInstanceID.java (95%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/task/FragmentInstanceTask.java (93%)
rename server/src/main/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/task/FragmentInstanceTaskStatus.java (96%)
rename
server/src/main/java/org/apache/iotdb/{mpp/execution/queue/IDIndexedAccessible.java
=> db/query/aggregation/RemovableAggregateResult.java} (73%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByEngineDataSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeEngineDataSet.java
rename server/src/main/java/org/apache/iotdb/db/query/{dataset =>
executor}/groupby/AlignedGroupByExecutor.java (96%)
rename server/src/main/java/org/apache/iotdb/db/query/{dataset =>
executor}/groupby/GroupByExecutor.java (96%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutorFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/EmptyQueueSlidingWindowGroupByExecutor.java
rename server/src/main/java/org/apache/iotdb/db/query/{dataset/groupby =>
executor/groupby/impl}/LocalAlignedGroupByExecutor.java (98%)
rename server/src/main/java/org/apache/iotdb/db/query/{dataset/groupby =>
executor/groupby/impl}/LocalGroupByExecutor.java (98%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/MonotonicQueueSlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/NormalQueueSlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/SmoothQueueSlidingWindowGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/AggrWindowIterator.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/hash/JSHashExecutor.java
=>
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/ITimeRangeIterator.java
(60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowIterator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/TimeRangeIteratorFactory.java
rename server/src/test/java/org/apache/iotdb/{ =>
db}/mpp/memory/MemoryPoolTest.java (99%)
rename server/src/test/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/L1PriorityQueueTest.java (98%)
rename server/src/test/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/L2PriorityQueueTest.java (98%)
rename server/src/test/java/org/apache/iotdb/{mpp/execution =>
db/mpp/schedule}/queue/QueueElement.java (97%)
copy
server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/{GroupByTimeDataSetTest.java
=> GroupByDataSetTest.java} (98%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByEngineDataSetTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/TimeRangeIteratorTest.java
