This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch calc_commons
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c48b443a53d modify serializeUseTemplate
new 0839a5d2675 refactor Metadata
new 3a1aa55aaf3 move some configs
new 02bc3f28161 move TemporaryQueryDataFileService
new 6bedeaf179b fix
The 4 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:
.../constant/BuiltinAggregationFunctionEnum.java | 6 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +
.../src/main/codegen/templates/ModeAccumulator.ftl | 4 +-
.../execution/operator/OperatorContext.java | 4 +-
.../operator/process/AbstractSortOperator.java | 4 +-
.../process/function/PartitionRecognizer.java | 2 +-
.../process/function/TableFunctionOperator.java | 1 -
.../process/window/TableWindowOperator.java | 2 +-
.../aggregation/TableModeAccumulator.java | 4 +-
.../grouped/GroupedModeAccumulator.java | 4 +-
.../relational/ColumnTransformerBuilder.java | 12 +--
.../plan/planner/TableOperatorGenerator.java | 10 +-
.../plan/relational/metadata/ITypeMetadata.java} | 15 +--
.../plan/udf/BuiltinAggregationFunction.java | 2 +-
.../plan/udf/BuiltinScalarFunction.java | 2 +-
.../udf/BuiltinTimeSeriesGeneratingFunction.java | 2 +-
.../db/calc_commons/plan/udf/TableUDFUtils.java | 1 -
.../plan/udf/UDFManagementService.java | 2 +-
.../plan/udf/UDTFForecast.java | 2 +-
.../dag/adapter/PointCollectorAdaptor.java | 2 +-
.../column/multi/MappableUDFColumnTransformer.java | 2 +-
.../dag/udf/UDFParametersFactory.java | 2 +-
.../transformation/dag/udf/UDTFExecutor.java | 10 +-
.../transformation/dag/util/InputRowUtils.java | 10 +-
.../transformation/datastructure/Cache.java | 2 +-
.../datastructure/SerializableList.java | 10 +-
.../iterator/ListForwardIterator.java | 2 +-
.../iterator/RowListForwardIterator.java | 6 +-
.../iterator/TVListForwardIterator.java | 6 +-
.../row/ElasticSerializableRowList.java | 8 +-
.../datastructure/row/SerializableRowList.java | 8 +-
.../tv/ElasticSerializableBinaryTVList.java | 8 +-
.../tv/ElasticSerializableTVList.java | 6 +-
.../datastructure/tv/SerializableTVList.java | 8 +-
.../datastructure/util/BinaryUtils.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 48 +---------
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 32 +++++--
.../relational/function/ITableFunctionFactory.java | 13 +--
...FunctionKind.java => TableFunctionFactory.java} | 32 +++----
.../relational/planner/node/AggregationNode.java | 34 -------
.../relational/planner/node/TableFunctionNode.java | 4 +-
.../planner/node/TableFunctionProcessorNode.java | 4 +-
.../AbstractTemporaryQueryDataFileService.java} | 66 ++++++-------
.../ITemporaryQueryDataFileServiceProvider.java} | 10 +-
.../processor/aggregate/AggregateProcessor.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../execution/aggregation/UDAFAccumulator.java | 4 +-
.../fragment/FragmentInstanceContext.java | 9 +-
.../execution/operator/AggregationUtil.java | 2 +-
.../operator/process/TransformOperator.java | 2 +-
.../execution/schedule/DriverTaskThread.java | 4 +-
.../plan/analyze/ExpressionAnalyzer.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../config/metadata/ShowFunctionsTask.java | 6 +-
.../db/queryengine/plan/expression/Expression.java | 2 +-
.../plan/expression/ExpressionFactory.java | 2 +-
.../plan/expression/binary/BinaryExpression.java | 2 +-
.../plan/expression/leaf/LeafOperand.java | 2 +-
.../plan/expression/multi/FunctionExpression.java | 6 +-
.../expression/other/CaseWhenThenExpression.java | 2 +-
.../expression/other/GroupByTimeExpression.java | 2 +-
.../plan/expression/ternary/TernaryExpression.java | 2 +-
.../plan/expression/unary/UnaryExpression.java | 2 +-
.../visitor/ColumnTransformerVisitor.java | 2 +-
.../visitor/IntermediateLayerVisitor.java | 2 +-
.../plan/optimization/AggregationPushDown.java | 2 +-
.../planner/DataNodeTableOperatorGenerator.java | 2 +-
.../plan/relational/metadata/Metadata.java | 10 +-
.../relational/metadata/TableMetadataImpl.java | 18 ----
.../db/queryengine/plan/udf/TreeUDFUtils.java | 1 +
...izableRowRecordListBackedMultiColumnWindow.java | 2 +-
...wRecordListBackedMultiColumnWindowIterator.java | 2 +-
...ticSerializableTVListBackedSingleColumnRow.java | 2 +-
...SerializableTVListBackedSingleColumnWindow.java | 2 +-
...ableTVListBackedSingleColumnWindowIterator.java | 2 +-
.../dag/input/QueryDataSetInputLayer.java | 4 +-
.../dag/intermediate/MultiInputLayer.java | 4 +-
.../SingleInputMultiReferenceLayer.java | 4 +-
.../SingleInputSingleReferenceLayer.java | 4 +-
.../transformation/dag/memory/SafetyLine.java | 2 +-
.../multi/MappableUDFQueryRowTransformer.java | 2 +-
.../transformer/multi/UDFQueryRowTransformer.java | 2 +-
.../multi/UDFQueryRowWindowTransformer.java | 2 +-
.../dag/transformer/multi/UDFQueryTransformer.java | 2 +-
.../multi/UniversalUDFQueryTransformer.java | 6 +-
.../dag/udf/UDAFInformationInferrer.java | 3 +-
.../transformation/dag/udf/UDTFContext.java | 5 +-
.../dag/udf/UDTFInformationInferrer.java | 3 +-
.../transformation/dag/util/LayerCacheUtils.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 5 +-
...NodeTemporaryQueryDataFileServiceProvider.java} | 29 +++---
.../db/service/TemporaryQueryDataFileService.java | 105 +--------------------
....service.ITemporaryQueryDataFileServiceProvider | 1 +
.../db/queryengine/execution/DataDriverTest.java | 6 +-
.../execution/operator/OperatorMemoryTest.java | 6 +-
.../operator/SortOperatorSortBranchTest.java | 7 +-
.../execution/operator/TreeSortOperatorTest.java | 7 +-
.../process/TableStreamSortOperatorTest.java | 14 +--
.../process/tvf/TableFunctionOperatorTest.java | 2 +-
.../plan/relational/analyzer/TSBSMetadata.java | 7 +-
.../plan/relational/analyzer/TestMetadata.java | 7 +-
.../ElasticSerializableRowListTest.java | 5 +-
.../ElasticSerializableTVListTest.java | 5 +-
.../transformation/datastructure/LRUCache.java | 2 +
.../datastructure/SerializableRowListTest.java | 2 +-
.../datastructure/SerializableTVListTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../apache/iotdb/db/utils/sort/SortUtilTest.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 57 +++++++++++
109 files changed, 349 insertions(+), 495 deletions(-)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/function/PartitionRecognizer.java (98%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/type/TypeCoercion.java
=> calc_commons/plan/relational/metadata/ITypeMetadata.java} (71%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/plan/udf/BuiltinAggregationFunction.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/plan/udf/BuiltinScalarFunction.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/plan/udf/BuiltinTimeSeriesGeneratingFunction.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/plan/udf/UDFManagementService.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/plan/udf/UDTFForecast.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/adapter/PointCollectorAdaptor.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/udf/UDFParametersFactory.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/udf/UDTFExecutor.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/util/InputRowUtils.java (82%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/Cache.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/SerializableList.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/iterator/ListForwardIterator.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/iterator/RowListForwardIterator.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/iterator/TVListForwardIterator.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/row/ElasticSerializableRowList.java
(97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/row/SerializableRowList.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/tv/ElasticSerializableBinaryTVList.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/tv/ElasticSerializableTVList.java
(97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/tv/SerializableTVList.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/datastructure/util/BinaryUtils.java (96%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeSinkException.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/function/ITableFunctionFactory.java
(73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/function/{FunctionKind.java
=> TableFunctionFactory.java} (56%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{service/TemporaryQueryDataFileService.java
=> node_commons/service/AbstractTemporaryQueryDataFileService.java} (67%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/pipe/plugin/DropPipePluginState.java
=>
datanode/src/main/java/org/apache/iotdb/db/node_commons/service/ITemporaryQueryDataFileServiceProvider.java}
(83%)
copy
iotdb-core/datanode/src/{test/java/org/apache/iotdb/db/service/DaemonTest.java
=>
main/java/org/apache/iotdb/db/service/DataNodeTemporaryQueryDataFileServiceProvider.java}
(56%)
create mode 100644
iotdb-core/datanode/src/main/resources/META-INF/services/org.apache.iotdb.db.node_commons.service.ITemporaryQueryDataFileServiceProvider
