This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/support_schema_evolution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 76c52fde895 store valid lenght inside sevo file & fix schema evolution
semantic
add ea7228114d0 Support pipe with sevo
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/it/utils/TestUtils.java | 14 +-
.../manual/AbstractPipeTableModelDualManualIT.java | 6 +-
.../enhanced/IoTDBPipeAlterTableColumnNameIT.java | 177 +++++++++++++++++++++
.../relational/it/db/it/IoTDBLoadTsFileIT.java | 3 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 17 ++
.../request/PipeTransferTsFilePieceReq.java | 8 +
.../request/PipeTransferTsFilePieceWithModReq.java | 8 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 2 +
.../async/handler/PipeTransferTsFileHandler.java | 58 +++++++
.../thrift/sync/IoTDBDataRegionSyncSink.java | 52 +++++-
.../execution/operator/source/SeriesScanUtil.java | 2 -
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +
.../plan/node/load/LoadSingleTsFileNode.java | 11 +-
.../planner/plan/node/load/LoadTsFileNode.java | 6 +-
.../plan/statement/crud/LoadTsFileStatement.java | 10 ++
.../db/storageengine/dataregion/DataRegion.java | 13 --
.../dataregion/tsfile/evolution/EvolvedSchema.java | 18 ++-
.../tsfile/evolution/SchemaEvolutionFile.java | 18 ++-
.../dataregion/tsfile/fileset/TsFileSet.java | 8 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 10 ++
.../plan/planner/node/load/LoadTsFileNodeTest.java | 2 +-
.../tsfile/evolution/EvolvedSchemaTest.java | 17 +-
.../tsfile/evolution/SchemaEvolutionFileTest.java | 7 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 96 +++++++----
.../thrift/request/PipeTransferFilePieceReq.java | 23 +++
26 files changed, 511 insertions(+), 80 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAlterTableColumnNameIT.java
