This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a42e6443170 Fix/include thrift lib and headers in cpp client (#12734)
add 0dbb3891b27 Pipe / Load / Subscription: Support new TsDataTypes
(STRING / BLOB / TIMESTAMP / DATE) (#12665)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 103 +++---
...TDBLoadTsFileIT.java => IoTDBLoadTsFileIT.java} | 394 +++++++++++++--------
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 105 ++++++
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 14 +
.../it/local/IoTDBSubscriptionBasicIT.java | 95 ++++-
.../java/org/apache/iotdb/pipe/api/access/Row.java | 46 ++-
.../java/org/apache/iotdb/pipe/api/type/Type.java | 15 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 8 +
.../payload/SubscriptionSessionDataSet.java | 9 +-
.../request/PipeTransferTabletRawReq.java | 70 ++--
.../connector/protocol/opcua/OpcUaConnector.java | 14 +
.../event/common/row/PipeDataTypeTransformer.java | 14 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 53 +--
.../tablet/TabletInsertionDataContainer.java | 99 ++++--
.../processor/aggregate/AggregateProcessor.java | 43 ++-
.../aggregate/TimeSeriesRuntimeState.java | 94 +++++
.../CustomizedReadableIntermediateResults.java | 49 ++-
.../IntermediateResultOperator.java | 41 ++-
.../numeric/AbstractSameTypeNumericOperator.java | 46 ++-
.../doubletype/FractionPoweredSumOperator.java | 56 ++-
.../specifictype/integertype/CountOperator.java | 54 ++-
.../window/datastructure/TimeSeriesWindow.java | 111 ++++++
.../AbstractSimpleTimeWindowingProcessor.java | 52 ++-
.../processor/AbstractWindowingProcessor.java | 45 ++-
.../downsampling/changing/ChangingValueFilter.java | 22 +-
.../sdt/SwingingDoorTrendingFilter.java | 20 +-
.../execution/load/AlignedChunkData.java | 124 ++++---
.../execution/load/NonAlignedChunkData.java | 65 ++--
.../plan/statement/crud/InsertTabletStatement.java | 4 +
.../connector/PipeDataNodeThriftRequestTest.java | 120 ++++---
.../db/pipe/event/PipeDataTypeTransformerTest.java | 13 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 40 ++-
32 files changed, 1511 insertions(+), 527 deletions(-)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/{IOTDBLoadTsFileIT.java
=> IoTDBLoadTsFileIT.java} (65%)
