This is an automated email from the ASF dual-hosted git repository. geniuspig pushed a commit to branch add_conf in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e57c7cfaeff3c3999dd609b1c16babc1ac33c084 Merge: 2286a0e 0fa6736 Author: Boris <[email protected]> AuthorDate: Wed Jan 6 12:18:41 2021 +0800 Merge branch 'master' into add_conf .github/pull_request_template.md | 93 +++ .github/workflows/sonar_and_coverall.yml | 4 +- .mvn/wrapper/maven-wrapper.properties | 2 +- .travis.yml | 10 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 60 +- .../java/org/apache/iotdb/cluster/ClusterMain.java | 28 +- .../iotdb/cluster/client/DataClientProvider.java | 17 +- .../cluster/client/async/AsyncClientPool.java | 87 +-- .../iotdb/cluster/client/sync/SyncClientPool.java | 39 +- .../apache/iotdb/cluster/config/ClusterConfig.java | 14 +- .../iotdb/cluster/config/ClusterConstant.java | 6 +- .../iotdb/cluster/coordinator/Coordinator.java | 598 +++++++++++++++++ .../apache/iotdb/cluster/log/LogDispatcher.java | 16 +- .../cluster/log/applier/AsyncDataLogApplier.java | 4 +- .../iotdb/cluster/log/catchup/CatchUpTask.java | 2 +- .../cluster/log/manage/CommittedEntryManager.java | 5 +- .../iotdb/cluster/log/manage/RaftLogManager.java | 22 +- .../log/manage/UnCommittedEntryManager.java | 10 +- .../apache/iotdb/cluster/metadata/CMManager.java | 14 +- .../cluster/partition/slot/SlotPartitionTable.java | 4 +- .../cluster/query/ClusterConcatPathOptimizer.java | 4 +- .../iotdb/cluster/query/ClusterPlanExecutor.java | 10 +- .../iotdb/cluster/query/ClusterPlanRouter.java | 9 - .../cluster/query/fill/ClusterPreviousFill.java | 11 +- .../cluster/query/manage/QueryCoordinator.java | 115 +--- .../iotdb/cluster/query/reader/DataSourceInfo.java | 2 +- .../apache/iotdb/cluster/server/ClientServer.java | 26 +- .../iotdb/cluster/server/DataClusterServer.java | 2 +- .../iotdb/cluster/server/MetaClusterServer.java | 17 +- .../apache/iotdb/cluster/server/RaftServer.java | 7 +- .../handlers/caller/AppendNodeEntryHandler.java | 6 +- .../server/handlers/caller/HeartbeatHandler.java | 2 +- .../cluster/server/member/DataGroupMember.java | 17 +- .../cluster/server/member/MetaGroupMember.java | 612 +++-------------- .../iotdb/cluster/server/member/RaftMember.java | 134 ++-- .../cluster/server/{ => monitor}/NodeReport.java | 3 +- .../manage => server/monitor}/NodeStatus.java | 41 +- .../monitor/NodeStatusManager.java} | 87 +-- .../iotdb/cluster/server/{ => monitor}/Peer.java | 2 +- .../iotdb/cluster/server/{ => monitor}/Timer.java | 15 +- .../cluster/server/service/BaseSyncService.java | 7 +- .../cluster/server/service/MetaAsyncService.java | 6 + .../cluster/server/service/MetaSyncService.java | 5 + .../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +- .../cluster/utils/nodetool/ClusterMonitor.java | 2 +- .../cluster/client/DataClientProviderTest.java | 12 +- .../org/apache/iotdb/cluster/common/IoTDBTest.java | 2 +- .../iotdb/cluster/integration/SingleNodeTest.java | 4 +- .../cluster/log/applier/DataLogApplierTest.java | 16 +- .../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 7 +- .../cluster/log/catchup/LogCatchUpTaskTest.java | 6 + .../log/catchup/SnapshotCatchUpTaskTest.java | 6 + .../manage/MetaSingleSnapshotLogManagerTest.java | 3 + .../cluster/log/snapshot/DataSnapshotTest.java | 10 + .../log/snapshot/MetaSimpleSnapshotTest.java | 2 + .../cluster/log/snapshot/PullSnapshotTaskTest.java | 5 + .../cluster/partition/SlotPartitionTableTest.java | 14 - .../apache/iotdb/cluster/query/BaseQueryTest.java | 5 +- .../query/ClusterPhysicalGeneratorTest.java | 10 +- .../cluster/query/ClusterPlanExecutorTest.java | 4 +- .../cluster/query/manage/QueryCoordinatorTest.java | 15 +- .../caller/AppendNodeEntryHandlerTest.java | 2 +- .../server/heartbeat/DataHeartbeatThreadTest.java | 5 + .../server/heartbeat/HeartbeatThreadTest.java | 5 + .../server/heartbeat/MetaHeartbeatThreadTest.java | 5 + .../cluster/server/member/DataGroupMemberTest.java | 5 + .../iotdb/cluster/server/member/MemberTest.java | 19 +- .../cluster/server/member/MetaGroupMemberTest.java | 76 ++- docs/SystemDesign/TsFile/Format.md | 4 +- docs/UserGuide/Client/Programming - Native API.md | 18 + docs/UserGuide/Client/Status Codes.md | 8 + docs/UserGuide/Concept/SDT.md | 63 ++ .../Ecosystem Integration/Zeppelin-IoTDB.md | 189 ++++++ .../DML Data Manipulation Language.md | 6 + .../Operation Manual/UDF User Defined Function.md | 511 ++++++++++++++ docs/UserGuide/Server/Cluster Setup.md | 2 +- docs/UserGuide/System Tools/Sync Tool.md | 2 +- docs/zh/SystemDesign/TsFile/Format.md | 4 +- docs/zh/UserGuide/Client/Command Line Interface.md | 2 +- .../UserGuide/Client/Programming - Native API.md | 14 + docs/zh/UserGuide/Client/Status Codes.md | 9 +- docs/zh/UserGuide/Concept/SDT.md | 61 ++ .../Ecosystem Integration/Zeppelin-IoTDB.md | 191 ++++++ .../DML Data Manipulation Language.md | 5 + .../Operation Manual/UDF User Defined Function.md | 512 ++++++++++++++ docs/zh/UserGuide/Server/Cluster Setup.md | 2 +- docs/zh/UserGuide/System Tools/Sync Tool.md | 2 +- example/pom.xml | 1 + example/udf/pom.xml | 82 +++ .../java/org/apache/iotdb/udf/UDTFExample.java | 56 ++ grafana/img/add_data_source.png | Bin 175851 -> 108927 bytes grafana/img/add_graph.png | Bin 723579 -> 364163 bytes grafana/img/edit_data_source.png | Bin 313673 -> 177869 bytes hadoop/pom.xml | 2 +- hive-connector/pom.xml | 8 +- .../main/java/org/apache/iotdb/jdbc/Config.java | 2 +- .../apache/iotdb/jdbc/IoTDBConnectionParams.java | 2 +- .../resources/conf/iotdb-engine.properties | 39 +- server/src/assembly/resources/conf/logback.xml | 24 +- .../org/apache/iotdb/db/auth/AuthException.java | 5 - .../org/apache/iotdb/db/auth/AuthorityChecker.java | 20 +- .../iotdb/db/auth/authorizer/BasicAuthorizer.java | 2 +- .../db/auth/authorizer/LocalFileAuthorizer.java | 2 +- .../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 10 +- .../apache/iotdb/db/auth/entity/PathPrivilege.java | 4 +- .../apache/iotdb/db/auth/entity/PrivilegeType.java | 2 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 120 +++- .../org/apache/iotdb/db/conf/IoTDBConstant.java | 12 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 49 +- .../org/apache/iotdb/db/engine/StorageEngine.java | 13 + .../db/engine/cache/TimeSeriesMetadataCache.java | 39 +- .../compaction/CompactionMergeTaskPoolManager.java | 32 +- .../db/engine/compaction/TsFileManagement.java | 22 +- .../level/LevelCompactionTsFileManagement.java | 190 +++--- .../no/NoCompactionTsFileManagement.java | 5 - .../engine/compaction/utils/CompactionUtils.java | 12 +- .../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +- .../iotdb/db/engine/merge/task/MergeFileTask.java | 2 +- .../io/LocalTextModificationAccessor.java | 61 +- .../engine/storagegroup/StorageGroupProcessor.java | 114 +++- .../db/engine/storagegroup/TsFileProcessor.java | 21 +- .../UDFRegistrationException.java} | 72 +- .../org/apache/iotdb/db/metadata/MManager.java | 8 + .../iotdb/db/metadata/logfile/MLogWriter.java | 24 +- .../main/java/org/apache/iotdb/db/qp/Planner.java | 9 +- .../apache/iotdb/db/qp/constant/DatetimeUtils.java | 40 ++ .../apache/iotdb/db/qp/constant/SQLConstant.java | 22 +- .../apache/iotdb/db/qp/executor/IPlanExecutor.java | 19 +- .../apache/iotdb/db/qp/executor/PlanExecutor.java | 187 +++++- .../org/apache/iotdb/db/qp/logical/Operator.java | 6 +- .../iotdb/db/qp/logical/crud/SFWOperator.java | 16 +- .../iotdb/db/qp/logical/crud/SelectOperator.java | 47 +- .../CreateFunctionOperator.java} | 99 +-- .../DropFunctionOperator.java} | 81 ++- .../ShowFunctionsOperator.java} | 78 ++- .../apache/iotdb/db/qp/physical/PhysicalPlan.java | 8 +- .../iotdb/db/qp/physical/crud/InsertRowPlan.java | 25 + .../physical/crud/InsertRowsOfOneDevicePlan.java | 154 +++++ .../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +- .../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 52 ++ .../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 133 ++++ .../iotdb/db/qp/physical/crud/UpdatePlan.java | 135 ---- .../sys/{ShowPlan.java => CreateFunctionPlan.java} | 114 ++-- .../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 81 ++- .../sys/ShowFunctionsPlan.java} | 75 +-- .../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 6 +- .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 157 +++-- .../iotdb/db/qp/strategy/LogicalGenerator.java | 7 +- .../iotdb/db/qp/strategy/PhysicalGenerator.java | 132 ++-- .../qp/strategy/optimizer/ConcatPathOptimizer.java | 192 ++++-- .../db/query/aggregation/AggregateResult.java | 2 +- .../db/query/aggregation/AggregationType.java | 1 - .../db/query/control/QueryResourceManager.java | 8 +- .../iotdb/db/query/control/TracingManager.java | 2 +- .../db/query/dataset/AlignByDeviceDataSet.java | 4 +- .../dataset/DirectAlignByTimeDataSet.java} | 74 +-- .../dataset/DirectNonAlignDataSet.java} | 72 +- .../apache/iotdb/db/query/dataset/ListDataSet.java | 16 +- .../db/query/dataset/NonAlignEngineDataSet.java | 28 +- .../dataset/RawQueryDataSetWithValueFilter.java | 4 +- .../dataset/RawQueryDataSetWithoutValueFilter.java | 24 +- .../db/query/dataset/ShowTimeseriesDataSet.java | 4 +- .../db/query/dataset/UDTFAlignByTimeDataSet.java | 277 ++++++++ .../apache/iotdb/db/query/dataset/UDTFDataSet.java | 152 +++++ .../db/query/dataset/UDTFNonAlignDataSet.java | 191 ++++++ .../dataset/groupby/GroupByEngineDataSet.java | 4 +- .../query/dataset/groupby/GroupByFillDataSet.java | 4 +- .../query/dataset/groupby/GroupByTimeDataSet.java | 4 +- .../groupby/GroupByWithValueFilterDataSet.java | 2 +- .../groupby/GroupByWithoutValueFilterDataSet.java | 2 +- .../iotdb/db/query/executor/IQueryRouter.java | 8 +- .../iotdb/db/query/executor/LastQueryExecutor.java | 18 +- .../iotdb/db/query/executor/QueryRouter.java | 51 +- .../db/query/executor/RawDataQueryExecutor.java | 22 +- .../iotdb/db/query/executor/UDTFQueryExecutor.java | 84 +++ .../org/apache/iotdb/db/query/udf/api/UDF.java | 44 ++ .../org/apache/iotdb/db/query/udf/api/UDTF.java | 121 ++++ .../apache/iotdb/db/query/udf/api/access/Row.java | 119 ++++ .../udf/api/access/RowIterator.java} | 94 +-- .../iotdb/db/query/udf/api/access/RowWindow.java | 61 ++ .../db/query/udf/api/collector/PointCollector.java | 137 ++++ .../api/customizer/config/UDFConfigurations.java} | 79 ++- .../api/customizer/config/UDTFConfigurations.java | 105 +++ .../parameter/UDFParameterValidator.java | 209 ++++++ .../api/customizer/parameter/UDFParameters.java | 149 +++++ .../api/customizer/strategy/AccessStrategy.java | 64 ++ .../strategy/RowByRowAccessStrategy.java | 61 ++ .../strategy/SlidingSizeWindowAccessStrategy.java | 123 ++++ .../strategy/SlidingTimeWindowAccessStrategy.java | 249 +++++++ .../UDFAttributeNotProvidedException.java} | 22 +- .../udf/api/exception/UDFException.java} | 22 +- .../UDFInputSeriesDataTypeNotValidException.java} | 29 +- .../UDFInputSeriesIndexNotValidException.java} | 24 +- .../UDFInputSeriesNumberNotValidException.java} | 27 +- .../exception/UDFParameterNotValidException.java} | 22 +- .../udf/builtin/BuiltinFunction.java} | 26 +- .../iotdb/db/query/udf/core/access/RowImpl.java | 93 +++ .../db/query/udf/core/access/RowIteratorImpl.java | 58 ++ .../db/query/udf/core/access/RowWindowImpl.java | 75 +++ .../db/query/udf/core/context/UDFContext.java | 134 ++++ .../db/query/udf/core/executor/UDTFExecutor.java | 115 ++++ .../iotdb/db/query/udf/core/input/InputLayer.java | 563 ++++++++++++++++ .../iotdb/db/query/udf/core/input/SafetyLine.java | 60 ++ .../udf/core/reader/LayerPointReader.java} | 93 +-- .../udf/core/reader/LayerRowReader.java} | 79 ++- .../udf/core/reader/LayerRowWindowReader.java} | 77 +-- .../core/transformer/RawQueryPointTransformer.java | 72 ++ .../db/query/udf/core/transformer/Transformer.java | 93 +++ .../core/transformer/UDFQueryRowTransformer.java} | 89 +-- .../transformer/UDFQueryRowWindowTransformer.java | 46 ++ .../udf/core/transformer/UDFQueryTransformer.java | 101 +++ .../query/udf/datastructure/SerializableList.java | 165 +++++ .../primitive/ElasticSerializableIntList.java | 109 +++ .../udf/datastructure/primitive/IntList.java} | 74 +-- .../primitive/SerializableIntList.java | 131 ++++ .../datastructure/primitive/WrappedIntArray.java | 90 +-- .../row/ElasticSerializableRowRecordList.java | 234 +++++++ .../row/SerializableRowRecordList.java | 245 +++++++ .../tv/ElasticSerializableBinaryTVList.java | 121 ++++ .../tv/ElasticSerializableTVList.java | 312 +++++++++ .../datastructure/tv/SerializableBinaryTVList.java | 79 +++ .../tv/SerializableBooleanTVList.java | 69 ++ .../datastructure/tv/SerializableDoubleTVList.java | 69 ++ .../datastructure/tv/SerializableFloatTVList.java | 69 ++ .../datastructure/tv/SerializableIntTVList.java | 69 ++ .../datastructure/tv/SerializableLongTVList.java | 69 ++ .../udf/datastructure/tv/SerializableTVList.java | 99 +++ .../udf/service/TemporaryQueryDataFileService.java | 136 ++++ .../iotdb/db/query/udf/service/UDFClassLoader.java | 83 +++ .../query/udf/service/UDFClassLoaderManager.java | 122 ++++ .../iotdb/db/query/udf/service/UDFLogWriter.java | 69 ++ .../udf/service/UDFRegistrationInformation.java | 78 +++ .../query/udf/service/UDFRegistrationService.java | 398 +++++++++++ .../apache/iotdb/db/rescon/MemTableManager.java | 116 ++++ .../org/apache/iotdb/db/rescon/SystemInfo.java | 1 + .../java/org/apache/iotdb/db/service/IoTDB.java | 10 +- .../org/apache/iotdb/db/service/ServiceType.java | 9 +- .../org/apache/iotdb/db/service/TSServiceImpl.java | 184 ++--- .../db/sync/receiver/load/FileLoaderManager.java | 4 +- .../db/sync/receiver/transfer/SyncServiceImpl.java | 25 +- .../iotdb/db/sync/sender/transfer/SyncClient.java | 48 +- .../org/apache/iotdb/db/utils/SchemaUtils.java | 29 +- .../org/apache/iotdb/db/utils/SerializeUtils.java | 12 +- .../iotdb/db/writelog/recover/LogReplayer.java | 9 - .../main/resources/iotdb/ui/static/iotdb-logo.png | Bin 1768 -> 1187 bytes .../apache/iotdb/db/auth/AuthorityCheckerTest.java | 144 ++++ .../{ => authorizer}/LocalFileAuthorizerTest.java | 295 ++++---- .../db/auth/authorizer/OpenIdAuthorizerTest.java | 107 +-- .../iotdb/db/auth/entity/PathPrivilegeTest.java} | 36 +- .../org/apache/iotdb/db/auth/entity/RoleTest.java | 33 +- .../org/apache/iotdb/db/auth/entity/UserTest.java | 44 ++ .../auth/{ => role}/LocalFileRoleAccessorTest.java | 13 +- .../auth/{ => role}/LocalFileRoleManagerTest.java | 45 +- .../auth/{ => user}/LocalFileUserAccessorTest.java | 13 +- .../auth/{ => user}/LocalFileUserManagerTest.java | 69 +- .../compaction/LevelCompactionMergeTest.java | 4 +- .../LevelCompactionTsFileManagementTest.java | 1 - .../NoCompactionTsFileManagementTest.java | 1 - .../apache/iotdb/db/engine/merge/MergeTest.java | 2 +- .../iotdb/db/engine/storagegroup/TTLTest.java | 2 +- .../iotdb/db/integration/IoTDBAddSubDeviceIT.java | 15 +- .../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 31 +- .../org/apache/iotdb/db/integration/IoTDBAsIT.java | 10 + .../db/integration/IoTDBAutoCreateSchemaIT.java | 19 +- .../iotdb/db/integration/IoTDBDeletionIT.java | 53 ++ .../apache/iotdb/db/integration/IoTDBLastIT.java | 13 +- .../db/integration/IoTDBLevelCompactionIT.java | 3 + .../iotdb/db/integration/IoTDBRestartIT.java | 40 +- .../db/integration/IoTDBRpcCompressionIT.java | 1 - .../iotdb/db/integration/IoTDBSimpleQueryIT.java | 6 +- .../iotdb/db/integration/IoTDBUDFManagementIT.java | 438 ++++++++++++ .../db/integration/IoTDBUDFWindowQueryIT.java | 513 ++++++++++++++ .../integration/IoTDBUDTFAlignByTimeQueryIT.java | 738 +++++++++++++++++++++ .../db/integration/IoTDBUDTFHybridQueryIT.java | 166 +++++ .../db/integration/IoTDBUDTFNonAlignQueryIT.java | 337 ++++++++++ .../IoTDBAggregationByLevelIT.java | 9 +- .../IoTDBAggregationDeleteIT.java | 16 +- .../{ => aggregation}/IoTDBAggregationIT.java | 2 +- .../IoTDBAggregationLargeDataIT.java | 247 +------ .../IoTDBAggregationSmallDataIT.java | 179 ++--- .../{ => auth}/IoTDBAuthorizationIT.java | 2 +- .../apache/iotdb/db/metadata/PartialPathTest.java | 34 +- .../iotdb/db/mqtt/BrokerAuthenticatorTest.java | 16 + .../iotdb/db/qp/plan/ConcatOptimizerTest.java | 7 +- .../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 213 +++++- .../db/query/aggregation/AggregateResultTest.java | 19 +- .../query/aggregation/DescAggregateResultTest.java | 126 ++++ .../iotdb/db/query/control/TracingManagerTest.java | 111 ++++ .../db/query/dataset/ShowTimeSeriesResultTest.java | 57 ++ .../query/dataset/UDTFAlignByTimeDataSetTest.java | 578 ++++++++++++++++ .../groupby}/GroupByEngineDataSetTest.java | 94 ++- .../{ => groupby}/GroupByFillDataSetTest.java | 2 +- .../{ => groupby}/GroupByLevelDataSetTest.java | 2 +- .../{ => groupby}/GroupByTimeDataSetTest.java | 2 +- .../ElasticSerializableRowRecordListTest.java | 224 +++++++ .../ElasticSerializableTVListTest.java | 251 +++++++ .../SerializableBinaryTVListTest.java | 80 +++ .../SerializableBooleanTVListTest.java | 80 +++ .../SerializableDoubleTVListTest.java | 79 +++ .../datastructure/SerializableFloatTVListTest.java | 78 +++ .../datastructure/SerializableIntTVListTest.java | 78 +++ .../udf/datastructure/SerializableListTest.java} | 85 ++- .../datastructure/SerializableLongTVListTest.java | 78 +++ .../SerializableRowRecordListTest.java | 143 ++++ .../udf/datastructure/SerializableTVListTest.java} | 79 ++- .../iotdb/db/query/udf/example/Accumulator.java | 90 +++ .../apache/iotdb/db/query/udf/example/Adder.java | 89 +++ .../apache/iotdb/db/query/udf/example/Counter.java | 76 +++ .../org/apache/iotdb/db/query/udf/example/Max.java | 72 ++ .../iotdb/db/query/udf/example/Multiplier.java | 62 ++ .../SlidingSizeWindowConstructorTester0.java | 53 ++ .../SlidingSizeWindowConstructorTester1.java | 62 ++ .../SlidingTimeWindowConstructionTester.java | 69 ++ .../db/query/udf/example/TerminateTester.java | 64 ++ .../iotdb/db/query/udf/example/ValidateTester.java | 46 ++ .../iotdb/db/utils/CopyOnReadLinkedListTest.java | 67 ++ .../iotdb/db/utils/EncodingInferenceUtilsTest.java | 45 ++ .../apache/iotdb/db/utils/EnvironmentUtils.java | 8 + .../org/apache/iotdb/db/utils/MemUtilsTest.java | 114 ++++ .../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 64 ++ .../apache/iotdb/db/utils/SerializeUtilsTest.java | 312 +++++++++ .../db/utils/datastructure/BinaryTVListTest.java | 58 ++ .../db/utils/datastructure/BooleanTVListTest.java | 62 ++ .../db/utils/datastructure/DoubleTVListTest.java | 72 ++ .../db/utils/datastructure/FloatTVListTest.java | 72 ++ .../db/utils/datastructure/IntTVListTest.java | 71 ++ .../db/utils/datastructure/LongTVListTest.java | 18 + .../apache/iotdb/db/writelog/PerformanceTest.java | 15 +- server/src/test/resources/iotdb-engine.properties | 2 + .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 2 + .../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 - .../java/org/apache/iotdb/session/Session.java | 124 +++- .../apache/iotdb/session/SessionConnection.java | 23 +- .../org/apache/iotdb/session/pool/SessionPool.java | 81 +++ .../apache/iotdb/session/IoTDBSessionSimpleIT.java | 140 +++- .../java/org/apache/iotdb/session/SessionUT.java | 2 +- site/src/main/.vuepress/config.js | 26 +- .../public/img/contributor-avatar/jlq.png | Bin 122303 -> 98500 bytes .../public/img/contributor-avatar/kfx.jpeg | Bin 134257 -> 119029 bytes .../public/img/contributor-avatar/xdh.jpg | Bin 136069 -> 123718 bytes .../.vuepress/public/img/contributor-avatar/yt.jpg | Bin 131028 -> 115804 bytes .../public/img/contributor-avatar/zss.jpg | Bin 98085 -> 91455 bytes site/src/main/.vuepress/public/img/home-Slide1.png | Bin 438294 -> 323108 bytes site/src/main/.vuepress/public/img/home-Slide2.png | Bin 440893 -> 323620 bytes site/src/main/.vuepress/public/img/home-Slide3.png | Bin 441335 -> 324332 bytes site/src/main/.vuepress/public/img/home-icon2.png | Bin 5529 -> 4463 bytes site/src/main/.vuepress/public/img/home-icon3.png | Bin 20637 -> 10753 bytes site/src/main/.vuepress/public/img/home-icon4.png | Bin 13225 -> 8681 bytes site/src/main/.vuepress/public/img/home-icon5.png | Bin 1989 -> 1531 bytes site/src/main/.vuepress/public/img/home-icon6.png | Bin 16502 -> 11537 bytes site/src/main/.vuepress/public/img/logo.png | Bin 31747 -> 21687 bytes site/src/main/.vuepress/public/img/tools.jpg | Bin 347602 -> 294103 bytes .../theme/global-components/Contributor.vue | 14 + spark-iotdb-connector/Readme.md | 32 +- spark-iotdb-connector/pom.xml | 2 +- spark-tsfile/README.md | 31 +- thrift/src/main/thrift/cluster.thrift | 7 + thrift/src/main/thrift/rpc.thrift | 12 + .../tsfile/encoding/bitpacking/IntPacker.java | 4 +- .../tsfile/encoding/bitpacking/LongPacker.java | 4 +- .../iotdb/tsfile/read/TsFileSequenceReader.java | 34 + .../org/apache/iotdb/tsfile/read/common/Field.java | 4 - .../apache/iotdb/tsfile/read/common/RowRecord.java | 2 +- .../query/dataset/DataSetWithTimeGenerator.java | 4 +- .../query/dataset/DataSetWithoutTimeGenerator.java | 4 +- .../tsfile/read/query/dataset/EmptyDataSet.java | 4 +- .../tsfile/read/query/dataset/QueryDataSet.java | 4 +- .../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +- .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 11 +- .../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +- .../tsfile/read/TimeSeriesMetadataReadTest.java | 87 +++ .../apache/iotdb/tsfile/utils/FileGenerator.java | 22 +- zeppelin-interpreter/README.md | 186 ------ zeppelin-interpreter/pom.xml | 32 +- 374 files changed, 19881 insertions(+), 3742 deletions(-) diff --cc server/src/assembly/resources/conf/iotdb-engine.properties index 39af273,dee4fd1..930e98f --- a/server/src/assembly/resources/conf/iotdb-engine.properties +++ b/server/src/assembly/resources/conf/iotdb-engine.properties @@@ -599,9 -631,3 +631,10 @@@ default_index_window_range=1 # buffer parameter for index processor. index_buffer_size=134217728 + +# whether enable data partition. If disabled, all data belongs to partition 0 +enable_partition=false + +# time range for partitioning data inside each storage group, the unit is second - partition_interval=604800 ++partition_interval=604800 ++
