This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch trigger-audit-log-v1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 944a342f861 almost
add 20ca8d14c91 integration with pipe
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 2 +
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 12 +++
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 10 ++-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 10 ++-
.../client/IoTDBConfigNodeSyncClientManager.java | 5 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 2 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 5 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 6 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 3 +
.../agent/task/connection/PipeEventCollector.java | 9 ++-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 6 ++
.../db/pipe/event/common/PipeInsertionEvent.java | 8 ++
.../common/deletion/PipeDeleteDataNodeEvent.java | 14 +++-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 10 +++
.../schema/PipeSchemaRegionWritePlanEvent.java | 10 ++-
.../statement/PipeStatementInsertionEvent.java | 6 ++
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 15 +++-
.../common/tablet/PipeRawTabletInsertionEvent.java | 24 +++++-
.../event/common/terminate/PipeTerminateEvent.java | 4 +
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 6 ++
.../common/tsfile/PipeTsFileInsertionEvent.java | 15 +++-
.../table/TsFileInsertionEventTableParser.java | 4 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 12 +++
.../protocol/thrift/IoTDBDataNodeReceiver.java | 5 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 15 +++-
.../client/IoTDBDataNodeSyncClientManager.java | 5 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 5 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 5 +-
.../sink/protocol/writeback/WriteBackSink.java | 22 +++++-
...istoricalDataRegionTsFileAndDeletionSource.java | 13 ++++
.../realtime/PipeRealtimeDataRegionSource.java | 21 +++++
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +
.../matcher/CachedSchemaPatternMatcher.java | 13 ++--
.../schemaregion/IoTDBSchemaRegionSource.java | 4 +-
.../PipePlanTablePrivilegeParseVisitor.java | 25 +++---
.../db/queryengine/common/MPPQueryContext.java | 12 +++
.../iotdb/db/queryengine/common/SessionInfo.java | 27 +++++++
.../InformationSchemaContentSupplierFactory.java | 91 ++++++++++++----------
.../analyze/load/LoadTsFileTableSchemaCache.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 68 ++++++++++++----
.../execution/config/TreeConfigTaskVisitor.java | 26 ++++---
.../plan/planner/TableOperatorGenerator.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 41 ++++++++--
.../db/pipe/consensus/DeletionResourceTest.java | 2 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 2 +
.../plan/relational/analyzer/AuthTest.java | 34 +++++---
.../apache/iotdb/commons/audit/IAuditEntity.java | 4 +
.../org/apache/iotdb/commons/audit/UserEntity.java | 77 +++++++++++++++++-
.../pipe/config/constant/PipeSinkConstant.java | 6 ++
.../pipe/config/constant/PipeSourceConstant.java | 6 ++
.../iotdb/commons/pipe/event/EnrichedEvent.java | 16 ++++
.../commons/pipe/event/PipeSnapshotEvent.java | 4 +
.../commons/pipe/event/PipeWritePlanEvent.java | 4 +
.../commons/pipe/event/ProgressReportEvent.java | 4 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 9 +++
.../pipe/sink/client/IoTDBClientManager.java | 7 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 12 ++-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../commons/pipe/sink/protocol/IoTDBSink.java | 15 ++++
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 5 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 4 +
.../iotdb/commons/pipe/source/IoTDBSource.java | 12 +++
.../pipe/datastructure/PipeCommitQueueTest.java | 8 ++
65 files changed, 704 insertions(+), 143 deletions(-)
