This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch UserDefinedTime
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 38c40b6319f Implemented load function for different time columns
(#17085)
add 2e46872766b Support stream DataFrame interface in iotdb python client
(#17035)
add 465170bac57 Adjust error message (#17084)
add d90397dc1ff [AINode] Call inference should only contain 1 input column
(#17087)
add 81f8e7e1fa3 [AINode] Fix the bug that AINode would not stop during
remove process (#17088)
add 0b25ea24c9c Support NULL time in First/Last/FirstBy/LastBy
aggregations (#17064)
add d06bced6c3a Support session with CPP conditional compilation for SSL.
(#17080)
add 82f7ca6dfc5 Pipe: Fixed the OPC UA client connection problem (#17083)
add b40b74b31ea Remove built-in jexl function in tree mode (#17092)
add 5802fa2e0ab Resolve the problem that everyone can alter table column
data type. (#17089)
add 8289238b119 Fix init time logic to ensure that time is not initiated‌
when the last cache will not updated during the execution phase (#17094)
add 52715f18e48 Verify nonexist measurement in an exist device if it
exists. (#17093)
add afcfd7419c1 fix (#17096)
new 6dc33198250 Merge remote-tracking branch 'origin/master' into
UserDefinedTime
The 1 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:
dependencies.json | 1 -
example/client-cpp-example/src/CMakeLists.txt | 157 ++++---
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 -
.../iotdb/ainode/it/AINodeCallInferenceIT.java | 14 +
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 7 +
.../db/it/query/IoTDBAggregationFirstByIT.java | 162 +++++++
.../it/query/IoTDBAggregationFirstByInGroupIT.java | 139 ++++++
.../iotdb/db/it/query/IoTDBAggregationFirstIT.java | 185 ++++++++
.../it/query/IoTDBAggregationFirstInGroupIT.java | 134 ++++++
.../db/it/query/IoTDBAggregationLastByIT.java | 164 +++++++
.../it/query/IoTDBAggregationLastByInGroupIT.java | 136 ++++++
.../iotdb/db/it/query/IoTDBAggregationLastIT.java | 176 ++++++++
.../db/it/query/IoTDBAggregationLastInGroupIT.java | 128 ++++++
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 18 +
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 235 ----------
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 32 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 36 ++
.../it/query/recent/IoTDBTableAggregationIT.java | 9 +
iotdb-client/client-cpp/pom.xml | 3 +
iotdb-client/client-cpp/src/main/CMakeLists.txt | 51 ++-
.../client-cpp/src/main/SessionConnection.cpp | 6 +
.../client-cpp/src/main/SessionConnection.h | 6 +-
.../client-cpp/src/main/ThriftConnection.cpp | 6 +
.../client-cpp/src/main/ThriftConnection.h | 4 +
iotdb-client/client-cpp/src/test/CMakeLists.txt | 92 ++--
iotdb-client/client-py/iotdb/Session.py | 8 +-
.../client-py/iotdb/utils/SessionDataSet.py | 19 +
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 68 +++
iotdb-client/client-py/session_example.py | 6 +
.../client-py/table_model_session_example.py | 4 +
.../client-py/tests/integration/test_dataframe.py | 50 +++
.../client/sync/CnToAnSyncRequestType.java | 7 +-
.../client/sync/SyncAINodeClientPool.java | 151 +++++++
.../consensus/request/ConfigPhysicalPlanType.java | 1 -
.../pipe/source/ConfigRegionListeningFilter.java | 2 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 22 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 48 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 79 +++-
.../sink/protocol/opcua/client/ClientRunner.java | 51 ++-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 34 +-
.../operator/process/ai/InferenceOperator.java | 7 +
.../relational/LastQueryAggTableScanOperator.java | 64 ++-
.../relational/aggregation/FirstAccumulator.java | 445 +++++++++++--------
.../relational/aggregation/FirstByAccumulator.java | 494 +++++++++++----------
.../aggregation/FirstByDescAccumulator.java | 180 ++++----
.../aggregation/FirstDescAccumulator.java | 168 +++----
.../relational/aggregation/LastAccumulator.java | 373 ++++++++++------
.../relational/aggregation/LastByAccumulator.java | 442 +++++++++---------
.../aggregation/LastByDescAccumulator.java | 234 +++++-----
.../aggregation/LastDescAccumulator.java | 198 ++++-----
.../source/relational/aggregation/Utils.java | 39 +-
.../grouped/GroupedFirstAccumulator.java | 390 +++++++++-------
.../grouped/GroupedFirstByAccumulator.java | 473 +++++++++++---------
.../grouped/GroupedLastAccumulator.java | 390 +++++++++-------
.../grouped/GroupedLastByAccumulator.java | 476 +++++++++++---------
.../execution/config/TableConfigTaskVisitor.java | 4 +
.../config/executor/ClusterConfigTaskExecutor.java | 23 +-
.../plan/planner/TableOperatorGenerator.java | 6 +-
.../udf/BuiltinTimeSeriesGeneratingFunction.java | 2 -
iotdb-core/node-commons/pom.xml | 4 -
.../iotdb/commons/client/ClientPoolFactory.java | 22 +
...susServiceClient.java => SyncAINodeClient.java} | 56 +--
.../pipe/config/constant/PipeSinkConstant.java | 5 +
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 368 ---------------
pom.xml | 6 -
65 files changed, 4528 insertions(+), 2793 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstByInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastByInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastInGroupIT.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionTreeRegressionMisc.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/CnToAnSyncRequestType.java
(86%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncAINodeClientPool.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/{SyncPipeConsensusServiceClient.java
=> SyncAINodeClient.java} (73%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFJexl.java
