This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a change to branch remove_swtich_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6ac266b065f add cached services
add 4595213f631 tmp
add c4ec742b2eb Fix TypeService review regressions and batch numeric input
loops
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/session/Session.java | 38 +-
.../java/org/apache/iotdb/session/SessionTest.java | 43 +
.../execution/aggregation/VarianceAccumulator.java | 27 +-
.../relational/aggregation/AvgAccumulator.java | 69 +-
.../relational/aggregation/ExtremeAccumulator.java | 35 +-
.../relational/aggregation/LastAccumulator.java | 4 +
.../relational/aggregation/LastByAccumulator.java | 4 +
.../relational/aggregation/MaxAccumulator.java | 37 +-
.../relational/aggregation/MinAccumulator.java | 37 +-
.../relational/aggregation/SumAccumulator.java | 62 +-
.../aggregation/TableCentralMomentAccumulator.java | 21 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 44 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 42 +-
.../grouped/GroupedVarianceAccumulator.java | 44 +-
.../grouped/rate/GroupedNaiveDeltaAccumulator.java | 49 +-
.../rate/GroupedNaiveIncreaseAccumulator.java | 49 +-
.../grouped/rate/GroupedNaiveIrateAccumulator.java | 31 +-
.../grouped/rate/GroupedNaiveRateAccumulator.java | 46 +-
.../rate/GroupedOrderedIrateAccumulator.java | 31 +-
.../aggregation/rate/NaiveDeltaAccumulator.java | 47 +-
.../aggregation/rate/NaiveIncreaseAccumulator.java | 47 +-
.../aggregation/rate/NaiveIrateAccumulator.java | 29 +-
.../aggregation/rate/NaiveRateAccumulator.java | 44 +-
.../aggregation/rate/OrderedDeltaAccumulator.java | 47 +-
.../rate/OrderedIncreaseAccumulator.java | 47 +-
.../aggregation/rate/OrderedRateAccumulator.java | 44 +-
.../aggregation/rate/RateFunctionValidation.java | 20 +
.../AbstractCastFunctionColumnTransformer.java | 14 +
.../scalar/CastFunctionColumnTransformer.java | 14 +
.../scalar/TryCastFunctionColumnTransformer.java | 14 +
.../org/apache/iotdb/calc/utils/TypeServices.java | 1770 +++++++++++++++++++-
.../aggregation/LastDescendingInputTest.java | 108 ++
.../aggregation/NumericBatchAggregationTest.java | 224 +++
.../aggregation/NumericMomentBatchTest.java | 157 ++
.../relational/aggregation/SumAccumulatorTest.java | 140 ++
.../aggregation/rate/RateBatchInputTest.java | 186 ++
.../column/unary/scalar/NumericCastBatchTest.java | 184 ++
.../aggregate/TimeSeriesRuntimeState.java | 10 +-
.../planner/plan/node/write/InsertTabletNode.java | 19 +-
.../org/apache/iotdb/db/utils/TypeServices.java | 94 +-
.../aggregate/TimeSeriesRuntimeStateTest.java | 76 +
.../node/write/InsertTabletNodeSerdeTest.java | 71 +
.../apache/iotdb/db/utils/TypeServicesTest.java | 13 +
.../library/frequency/UDFEnvelopeAnalysis.java | 4 +-
.../org/apache/iotdb/library/UDFEnvelopeTest.java | 23 +
pom.xml | 2 +-
46 files changed, 3573 insertions(+), 588 deletions(-)
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/LastDescendingInputTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericBatchAggregationTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericMomentBatchTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/SumAccumulatorTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateBatchInputTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/transformation/dag/column/unary/scalar/NumericCastBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/aggregate/TimeSeriesRuntimeStateTest.java
