This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch IoTDBLocal
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 72dab4f924b fix
add 5c2b0adee66 fix some
add cd02c6dc174 fix some
add d8ac6a46f2a fix some
No new revisions were added by this update.
Summary of changes:
.../iotdblocal/CreateTableProbeFunction.java | 12 +-
...ava => DeviceIdListInProcessTableFunction.java} | 71 ++++-----
...unction.java => DeviceIdListTableFunction.java} | 76 +++++----
.../DeviceNameEnrichBeforeStartTableFunction.java | 144 +++++++++++++++++
.../DeviceNameEnrichInProcessTableFunction.java | 120 ++++++++------
.../iotdblocal/DropTableProbeFunction.java | 11 +-
.../relational/iotdblocal/InsertProbeFunction.java | 15 +-
...QueryUdafAtBeforeDestroyAggregateFunction.java} | 37 +++--
...alQueryUdafAtBeforeStartAggregateFunction.java} | 51 ++++--
...LocalQueryUdafInAddInputAggregateFunction.java} | 78 ++++-----
...lQueryUdafInCombineStateAggregateFunction.java} | 78 ++++-----
...alQueryUdafInOutputFinalAggregateFunction.java} | 40 +++--
...nction.java => MutatingQueryProbeFunction.java} | 15 +-
.../relational/it/db/it/udf/IoTDBLocalIT.java | 177 +++++++++++++++++++++
.../UserDefinedAggregateFunctionAccumulator.java | 23 ++-
.../GroupedUserDefinedAggregateAccumulator.java | 11 +-
.../udf/UserDefineScalarFunctionTransformer.java | 10 +-
.../iotdb/db/protocol/session/SessionManager.java | 26 +--
.../fragment/FragmentInstanceManager.java | 3 +-
.../execution/schedule/task/DriverTask.java | 21 +--
.../iotdb/db/queryengine/plan/Coordinator.java | 27 ++++
.../SimpleFragmentParallelPlanner.java | 2 -
.../plan/planner/plan/FragmentInstance.java | 13 --
.../distribute/TableModelQueryFragmentPlanner.java | 2 -
.../db/queryengine/udf/InternalQueryExecutor.java | 14 +-
.../iotdb/db/queryengine/udf/UDFResultSetImpl.java | 41 ++++-
26 files changed, 774 insertions(+), 344 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/TsBlockSerdeFactory.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/CreateTableProbeFunction.java
(72%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/{IoTDBLocalLogTableFunction.java
=> DeviceIdListInProcessTableFunction.java} (70%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/{IoTDBLocalLogTableFunction.java
=> DeviceIdListTableFunction.java} (67%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameEnrichBeforeStartTableFunction.java
copy
example/udf/src/main/java/org/apache/iotdb/udf/table/ExcludeColumnExample.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameEnrichInProcessTableFunction.java
(50%)
copy
iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/NodeType.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DropTableProbeFunction.java
(74%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigRegionId.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/InsertProbeFunction.java
(71%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyCount.java
=> iotdblocal/LocalQueryUdafAtBeforeDestroyAggregateFunction.java} (70%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyCount.java
=> iotdblocal/LocalQueryUdafAtBeforeStartAggregateFunction.java} (61%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/{IoTDBLocalLogAggregateFunction.java
=> LocalQueryUdafInAddInputAggregateFunction.java} (60%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/{IoTDBLocalLogAggregateFunction.java
=> LocalQueryUdafInCombineStateAggregateFunction.java} (59%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyCount.java
=> iotdblocal/LocalQueryUdafInOutputFinalAggregateFunction.java} (68%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/{SecretTableQueryFunction.java
=> MutatingQueryProbeFunction.java} (81%)
