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 616b34b343d multiple refactors
new 93a97ed6e95 multiple refactors
new 85010f7ea88 multiple refactors
new ec6e5de96b8 multiple refactors
new e1f2247535d multiple refactors
new 652cb02d014 multiple refactors
new d54e316f9ee multiple refactors
new 954731b1a51 multiple refactors
new 814cb3c90e7 multiple refactors
new 286f049c433 multiple refactors
new ade03e2d1fd multiple refactors
new 58a688e8f83 multiple refactors
new 49a2e7a1d12 multiple refactors
new f671bea1893 multiple refactors
new 64e1313f5b4 multiple refactors
The 14 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:
example/udf/pom.xml | 6 +
.../java/org/apache/iotdb/udf/UDAFExample.java | 106 +-
.../v1/handler/StatementConstructionHandler.java | 111 +-
.../iotdb/rest/protocol/utils/TypeServices.java | 162 +
.../v1/handler/StatementConstructionHandler.java | 111 +-
.../v2/handler/StatementConstructionHandler.java | 111 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 28 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 38 +-
.../org/apache/iotdb/isession/TypeServices.java | 65 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 177 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 96 +-
.../java/org/apache/iotdb/rpc/TypeServices.java | 162 +
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 41 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java | 176 +
.../iotdb/rpc/stmt/PreparedParameterSerdeTest.java | 12 +
.../payload/SubscriptionRecordHandler.java | 74 +-
.../session/subscription/payload/TypeServices.java | 115 +
.../subscription/payload/TypeServicesTest.java | 69 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 45 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 45 +
.../merge/comparator/JoinKeyComparatorFactory.java | 36 +-
.../relational/MergeSortFullOuterJoinOperator.java | 6 +-
.../AbstractApproxMostFrequentAccumulator.java | 3 +-
.../AbstractApproxPercentileAccumulator.java | 59 +-
.../relational/aggregation/AccumulatorFactory.java | 58 +-
.../ApproxCountDistinctAccumulator.java | 53 +-
.../relational/aggregation/AvgAccumulator.java | 180 +-
.../relational/aggregation/ExtremeAccumulator.java | 167 +-
.../relational/aggregation/FirstAccumulator.java | 238 +-
.../relational/aggregation/FirstByAccumulator.java | 219 +-
.../relational/aggregation/LastAccumulator.java | 268 +-
.../relational/aggregation/LastByAccumulator.java | 211 +-
.../relational/aggregation/MaxAccumulator.java | 189 +-
.../relational/aggregation/MinAccumulator.java | 189 +-
.../aggregation/PercentileAccumulator.java | 128 +-
.../relational/aggregation/SumAccumulator.java | 174 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 345 +-
.../aggregation/TableModeAccumulator.java | 668 +---
.../source/relational/aggregation/Utils.java | 2 -
...AbstractGroupedApproxPercentileAccumulator.java | 54 +-
.../GroupedApproxCountDistinctAccumulator.java | 52 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 120 +-
.../grouped/GroupedExtremeAccumulator.java | 322 +-
.../grouped/GroupedFirstAccumulator.java | 443 +--
.../grouped/GroupedFirstByAccumulator.java | 446 +--
.../grouped/GroupedLastAccumulator.java | 442 +--
.../grouped/GroupedLastByAccumulator.java | 446 +--
.../aggregation/grouped/GroupedMaxAccumulator.java | 351 +-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 658 +---
.../aggregation/grouped/GroupedMinAccumulator.java | 479 +--
.../grouped/GroupedModeAccumulator.java | 289 +-
.../grouped/GroupedPercentileAccumulator.java | 73 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 114 +-
.../relational/ColumnTransformerBuilder.java | 122 +-
.../calc/plan/planner/CommonOperatorUtils.java | 129 +-
.../calc/plan/planner/TableOperatorGenerator.java | 148 +-
.../AbstractGreatestLeastColumnTransformer.java | 46 +-
.../multi/BinaryGreatestColumnTransformer.java | 2 +-
.../column/multi/BinaryLeastColumnTransformer.java | 2 +-
.../multi/BooleanGreatestColumnTransformer.java | 2 +-
.../multi/BooleanLeastColumnTransformer.java | 2 +-
.../multi/DoubleGreatestColumnTransformer.java | 2 +-
.../column/multi/DoubleLeastColumnTransformer.java | 2 +-
.../multi/FloatGreatestColumnTransformer.java | 2 +-
.../column/multi/FloatLeastColumnTransformer.java | 2 +-
.../multi/Int32GreatestColumnTransformer.java | 2 +-
.../column/multi/Int32LeastColumnTransformer.java | 2 +-
.../multi/Int64GreatestColumnTransformer.java | 2 +-
.../column/multi/Int64LeastColumnTransformer.java | 2 +-
.../dag/column/unary/InColumnTransformer.java | 220 +-
.../AbstractCastFunctionColumnTransformer.java | 353 +-
.../scalar/CastFunctionColumnTransformer.java | 42 +-
.../unary/scalar/FormatColumnTransformer.java | 37 +-
.../unary/scalar/RoundColumnTransformer.java | 36 +-
.../scalar/RoundFunctionColumnTransformer.java | 37 +-
.../scalar/TryCastFunctionColumnTransformer.java | 43 +-
.../transformation/dag/util/CastFunctionUtils.java | 246 +-
.../org/apache/iotdb/calc/utils/TypeServices.java | 3471 +++++++++++++++++++-
.../apache/iotdb/calc/utils/TypeServicesTest.java | 206 ++
.../processor/aggregate/AggregateProcessor.java | 49 +-
.../aggregate/TimeSeriesRuntimeState.java | 21 +
.../org/apache/iotdb/db/utils/TypeServices.java | 51 +
.../plan/relational/type/InternalTypeManager.java | 67 +-
.../iotdb/commons/udf/builtin/TypeServices.java | 671 ++++
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 106 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 105 +-
.../commons/udf/builtin/UDTFChangePoints.java | 178 +-
.../commons/udf/builtin/UDTFCommonDerivative.java | 41 +-
.../udf/builtin/UDTFCommonValueDifference.java | 42 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 267 +-
.../udf/builtin/UDTFContinuouslySatisfy.java | 79 +-
.../iotdb/commons/udf/builtin/UDTFDerivative.java | 11 +
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 53 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 39 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 53 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 40 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 162 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 36 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 149 +-
.../udf/builtin/UDTFNonNegativeDerivative.java | 48 +-
.../builtin/UDTFNonNegativeValueDifference.java | 49 +-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 153 +-
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 136 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 65 +-
.../commons/udf/builtin/UDTFValueDifference.java | 12 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 42 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 107 +-
.../relational/type/InternalTypeManagerTest.java | 61 +
.../udf/utils/UDFDataTypeTransformerTest.java | 71 +
library-udf/pom.xml | 5 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 13 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 12 +
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 62 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 53 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 38 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 218 +-
.../iotdb/library/dprofile/UDAFQuantile.java | 135 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 99 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 299 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 50 +-
.../dprofile/util/ExactOrderStatistics.java | 208 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 36 +-
.../iotdb/library/drepair/UDTFValueFill.java | 36 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 37 +-
.../library/frequency/UDFEnvelopeAnalysis.java | 43 +-
.../apache/iotdb/library/match/UDAFDTWMatch.java | 26 +-
.../iotdb/library/match/UDAFPatternMatch.java | 26 +-
.../apache/iotdb/library/util/TypeServices.java | 300 ++
.../java/org/apache/iotdb/library/util/Util.java | 79 +-
129 files changed, 8938 insertions(+), 10193 deletions(-)
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/utils/TypeServices.java
create mode 100644
iotdb-client/isession/src/main/java/org/apache/iotdb/isession/TypeServices.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TypeServices.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/TypeServices.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/payload/TypeServicesTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/TypeServices.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/queryengine/plan/relational/type/InternalTypeManagerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/UDFDataTypeTransformerTest.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/util/TypeServices.java
