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>
public class RewriteDataFilesAction extends BaseRewriteDataFilesAction<RewriteDataFilesAction>
-
-
Constructor Summary
Constructors Constructor Description RewriteDataFilesAction(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Table table)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
commit(SnapshotUpdate<?> update)
protected FileIO
fileIO()
RewriteDataFilesAction
maxParallelism(int parallelism)
protected java.lang.String
metadataTableName(java.lang.String tableName, MetadataTableType type)
protected java.lang.String
metadataTableName(MetadataTableType type)
protected java.util.List<DataFile>
rewriteDataForTasks(java.util.List<CombinedScanTask> combinedScanTasks)
protected RewriteDataFilesAction
self()
ThisT
set(java.lang.String property, java.lang.String value)
-
Methods inherited from class org.apache.iceberg.actions.BaseRewriteDataFilesAction
caseSensitive, caseSensitive, encryptionManager, execute, filter, outputSpecId, spec, splitLookback, splitOpenFileCost, table, targetSizeInBytes
-
-
-
-
Constructor Detail
-
RewriteDataFilesAction
public RewriteDataFilesAction(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Table table)
-
-
Method Detail
-
fileIO
protected FileIO fileIO()
- Specified by:
fileIO
in classBaseRewriteDataFilesAction<RewriteDataFilesAction>
-
rewriteDataForTasks
protected java.util.List<DataFile> rewriteDataForTasks(java.util.List<CombinedScanTask> combinedScanTasks)
- Specified by:
rewriteDataForTasks
in classBaseRewriteDataFilesAction<RewriteDataFilesAction>
-
self
protected RewriteDataFilesAction self()
-
maxParallelism
public RewriteDataFilesAction maxParallelism(int parallelism)
-
set
public ThisT set(java.lang.String property, java.lang.String value)
- Specified by:
set
in interfaceSnapshotUpdateAction<ThisT,R>
-
commit
protected void commit(SnapshotUpdate<?> update)
-
metadataTableName
protected java.lang.String metadataTableName(MetadataTableType type)
-
metadataTableName
protected java.lang.String metadataTableName(java.lang.String tableName, MetadataTableType type)
-
-