public class RewriteDataFilesAction extends BaseRewriteDataFilesAction<RewriteDataFilesAction>
Constructor and Description |
---|
RewriteDataFilesAction(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
Table table) |
Modifier and Type | Method and Description |
---|---|
protected void |
commit(SnapshotUpdate<?> update) |
protected FileIO |
fileIO() |
RewriteDataFilesAction |
maxParallelism(int parallelism) |
protected java.lang.String |
metadataTableName(MetadataTableType type) |
protected java.lang.String |
metadataTableName(java.lang.String tableName,
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) |
caseSensitive, caseSensitive, encryptionManager, execute, filter, outputSpecId, spec, splitLookback, splitOpenFileCost, table, targetSizeInBytes, useStartingSequenceNumber
public RewriteDataFilesAction(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Table table)
protected FileIO fileIO()
fileIO
in class BaseRewriteDataFilesAction<RewriteDataFilesAction>
protected java.util.List<DataFile> rewriteDataForTasks(java.util.List<CombinedScanTask> combinedScanTasks)
rewriteDataForTasks
in class BaseRewriteDataFilesAction<RewriteDataFilesAction>
protected RewriteDataFilesAction self()
public RewriteDataFilesAction maxParallelism(int parallelism)
public ThisT set(java.lang.String property, java.lang.String value)
set
in interface SnapshotUpdateAction<ThisT,R>
protected void commit(SnapshotUpdate<?> update)
protected java.lang.String metadataTableName(MetadataTableType type)
protected java.lang.String metadataTableName(java.lang.String tableName, MetadataTableType type)