This is an automated email from the ASF dual-hosted git repository.
critas pushed a change to branch wx_script
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d853503820c fix schema it
add edf87ff4fc2 Load IT: Stabilized the
testLoadAutoCreateWithoutInsertPermission test (#15408)
add 923bb2c347c Add APPROX_COUNT_DISTINCT Function
add a17ec6771be Add authorization for metric prometheus report (#15363)
add bb087e7bc64 [Py-client] Query Timestamp type of values return readable
format
add db3a3845475 Add TableFunctionHandle for TVF
add 665e18f6f63 docker: support configuring JVM memory environment
variables in docker-compose file:IOTDB_JMX_OPTS for
datanode,CONFIGNODE_JMX_OPTS for confignode (#15413)
add 34e8071ba99 Merge branch 'master' into wx_script
add 80808d46d87 restore ainode version
No new revisions were added by this update.
Summary of changes:
.../DockerCompose/docker-compose-host-3c3d.yml | 2 +
.../DockerCompose/docker-compose-standalone.yml | 4 +-
.../main/DockerCompose/replace-conf-from-env.sh | 11 +-
.../iotdb/udf/table/ExcludeColumnExample.java | 11 +-
.../org/apache/iotdb/udf/table/RepeatExample.java | 17 +-
.../org/apache/iotdb/udf/table/SplitExample.java | 27 +-
.../example/relational/MyErrorTableFunction.java | 15 +-
.../udf/example/relational/MyExcludeColumn.java | 11 +-
.../udf/example/relational/MyRepeatWithIndex.java | 17 +-
.../example/relational/MyRepeatWithoutIndex.java | 17 +-
.../udf/example/relational/MySelectColumn.java | 11 +-
.../db/query/udf/example/relational/MySplit.java | 27 +-
.../it/env/cluster/config/MppConfigNodeConfig.java | 12 +
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 13 +-
.../env/remote/config/RemoteConfigNodeConfig.java | 10 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 13 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 11 +-
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 5 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 92 +++++-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 21 ++
.../manual/basic/IoTDBPipeWithLoadIT.java | 28 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 69 +++++
.../api/relational/EmptyTableFunctionHandle.java | 22 +-
.../iotdb/udf/api/relational/TableFunction.java | 10 +-
.../relational/table/MapTableFunctionHandle.java | 186 ++++++++++++
.../relational/table/TableFunctionAnalysis.java | 21 +-
.../table/TableFunctionHandle.java} | 15 +-
iotdb-client/client-py/README.md | 4 +-
iotdb-client/client-py/iotdb/Session.py | 18 +-
iotdb-client/client-py/iotdb/SessionPool.py | 4 +-
iotdb-client/client-py/iotdb/utils/Field.py | 29 +-
.../client-py/iotdb/utils/SessionDataSet.py | 19 +-
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 38 ++-
iotdb-client/client-py/iotdb/utils/rpc_utils.py | 41 +++
iotdb-client/client-py/requirements.txt | 1 +
iotdb-client/client-py/resources/pyproject.toml | 3 +-
.../session_aligned_timeseries_example.py | 4 +-
iotdb-client/client-py/session_example.py | 4 +-
iotdb-client/client-py/session_pool_example.py | 2 +-
iotdb-client/client-py/session_ssl_example.py | 4 +-
.../client-py/table_model_session_example.py | 4 +-
.../integration/tablet_performance_comparison.py | 4 +-
.../tests/integration/test_new_data_types.py | 12 +-
.../tests/integration/test_tablemodel_query.py | 22 +-
iotdb-core/ainode/pyproject.toml | 2 +-
.../relational/aggregation/AccumulatorFactory.java | 5 +
.../ApproxCountDistinctAccumulator.java | 265 +++++++++++++++++
.../source/relational/aggregation/HyperLogLog.java | 246 ++++++++++++++++
.../aggregation/HyperLogLogStateFactory.java | 88 ++++++
.../GroupedApproxCountDistinctAccumulator.java | 314 +++++++++++++++++++++
.../aggregation/grouped/array/BinaryBigArray.java | 4 -
.../grouped/array/HyperLogLogBigArray.java | 84 ++++++
.../aggregation/grouped/array/MapBigArray.java | 4 -
.../aggregation/grouped/array/ObjectBigArray.java | 12 +-
.../plan/planner/TableOperatorGenerator.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 30 +-
.../relational/analyzer/StatementAnalyzer.java | 1 +
.../TableFunctionInvocationAnalysis.java | 8 +
.../relational/metadata/TableMetadataImpl.java | 15 +
.../plan/relational/planner/RelationPlanner.java | 2 +-
.../rule/ImplementTableFunctionSource.java | 4 +-
.../rule/PruneTableFunctionProcessorColumns.java | 2 +-
.../PruneTableFunctionProcessorSourceColumns.java | 2 +-
.../relational/planner/node/TableFunctionNode.java | 57 ++--
.../planner/node/TableFunctionProcessorNode.java | 51 ++--
.../optimizations/UnaliasSymbolReferences.java | 6 +-
.../plan/relational/sql/parser/AstBuilder.java | 9 +
.../iotdb/db/utils/constant/SqlConstant.java | 2 +
.../db/queryengine/plan/function/Exclude.java | 11 +-
.../iotdb/db/queryengine/plan/function/Repeat.java | 18 +-
.../iotdb/db/queryengine/plan/function/Split.java | 27 +-
.../relational/analyzer/TableFunctionTest.java | 92 +++---
.../assertions/TableFunctionProcessorMatcher.java | 178 +-----------
iotdb-core/metrics/interface/pom.xml | 5 +
.../apache/iotdb/metrics/config/MetricConfig.java | 38 +++
.../metrics/config/MetricConfigDescriptor.java | 19 ++
.../reporter/prometheus/PrometheusReporter.java | 62 +++-
.../conf/iotdb-system.properties.template | 11 +
.../TableBuiltinAggregationFunction.java | 2 +
.../relational/tvf/CapacityTableFunction.java | 22 +-
.../relational/tvf/CumulateTableFunction.java | 27 +-
.../builtin/relational/tvf/HOPTableFunction.java | 31 +-
.../relational/tvf/SessionTableFunction.java | 19 +-
.../relational/tvf/TumbleTableFunction.java | 25 +-
.../relational/tvf/VariationTableFunction.java | 20 +-
.../thrift-commons/src/main/thrift/common.thrift | 3 +-
scripts/conf/confignode-env.sh | 31 +-
scripts/conf/datanode-env.sh | 35 ++-
91 files changed, 2307 insertions(+), 521 deletions(-)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/EmptyTableFunctionHandle.java
(69%)
create mode 100644
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/table/MapTableFunctionHandle.java
copy iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/{State.java =>
relational/table/TableFunctionHandle.java} (81%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/ApproxCountDistinctAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/HyperLogLog.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/HyperLogLogStateFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedApproxCountDistinctAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/HyperLogLogBigArray.java
