Package org.apache.iceberg.flink.actions
Class RewriteDataFilesAction
java.lang.Object
org.apache.iceberg.actions.BaseRewriteDataFilesAction<RewriteDataFilesAction>
org.apache.iceberg.flink.actions.RewriteDataFilesAction
- All Implemented Interfaces:
Action<RewriteDataFilesAction,
,RewriteDataFilesActionResult> SnapshotUpdateAction<RewriteDataFilesAction,
RewriteDataFilesActionResult>
-
Constructor Summary
ConstructorDescriptionRewriteDataFilesAction
(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Table table) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
commit
(SnapshotUpdate<?> update) protected FileIO
fileIO()
maxParallelism
(int parallelism) protected String
metadataTableName
(String tableName, MetadataTableType type) protected String
rewriteDataForTasks
(List<CombinedScanTask> combinedScanTasks) protected RewriteDataFilesAction
self()
Methods inherited from class org.apache.iceberg.actions.BaseRewriteDataFilesAction
caseSensitive, caseSensitive, encryptionManager, execute, filter, outputSpecId, spec, splitLookback, splitOpenFileCost, table, targetSizeInBytes, useStartingSequenceNumber
-
Constructor Details
-
RewriteDataFilesAction
public RewriteDataFilesAction(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Table table)
-
-
Method Details
-
fileIO
- Specified by:
fileIO
in classBaseRewriteDataFilesAction<RewriteDataFilesAction>
-
rewriteDataForTasks
- Specified by:
rewriteDataForTasks
in classBaseRewriteDataFilesAction<RewriteDataFilesAction>
-
self
-
maxParallelism
-
set
- Specified by:
set
in interfaceSnapshotUpdateAction<ThisT,
R>
-
commit
-
metadataTableName
-
metadataTableName
-