You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ge...@apache.org on 2021/01/06 04:19:25 UTC
[iotdb] branch add_conf created (now e57c7cf)
This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a change to branch add_conf
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at e57c7cf Merge branch 'master' into add_conf
This branch includes the following new commits:
new 2286a0e add config
new e57c7cf Merge branch 'master' into add_conf
The 2 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.
[iotdb] 02/02: Merge branch 'master' into add_conf
Posted by ge...@apache.org.
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 <96...@qq.com>
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
++
[iotdb] 01/02: add config
Posted by ge...@apache.org.
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 2286a0e884b85b2b3a7c4f58b8c3ebfbe23ad8d3
Author: Boris <96...@qq.com>
AuthorDate: Wed Jan 6 12:17:56 2021 +0800
add config
---
server/src/assembly/resources/conf/iotdb-engine.properties | 8 +++++++-
.../src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 ++++
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git a/server/src/assembly/resources/conf/iotdb-engine.properties b/server/src/assembly/resources/conf/iotdb-engine.properties
index 05d773e..39af273 100644
--- a/server/src/assembly/resources/conf/iotdb-engine.properties
+++ b/server/src/assembly/resources/conf/iotdb-engine.properties
@@ -598,4 +598,10 @@ concurrent_index_build_thread=0
default_index_window_range=10
# buffer parameter for index processor.
-index_buffer_size=134217728
\ No newline at end of file
+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
\ No newline at end of file
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
index c6b7847..5117aba 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
@@ -560,6 +560,10 @@ public class IoTDBDescriptor {
//if using org.apache.iotdb.db.auth.authorizer.OpenIdAuthorizer, openID_url is needed.
conf.setOpenIdProviderUrl(properties.getProperty("openID_url", ""));
+ conf.setEnablePartition(Boolean.parseBoolean(properties.getProperty("enable_partition", conf.isEnablePartition() + "")));
+
+ conf.setPartitionInterval(Long.parseLong(properties.getProperty("partition_interval", conf.getPartitionInterval() + "")));
+
// At the same time, set TSFileConfig
TSFileDescriptor.getInstance().getConfig()
.setTSFileStorageFs(FSType.valueOf(