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

Modifier and Type	Method	Description
protected void	commit(SnapshotUpdate<?> update)
protected FileIO	fileIO()
RewriteDataFilesAction	maxParallelism(int parallelism)
protected String	metadataTableName(String tableName, MetadataTableType type)
protected String	metadataTableName(MetadataTableType type)
protected List<DataFile>	rewriteDataForTasks(List<CombinedScanTask> combinedScanTasks)
protected RewriteDataFilesAction	self()
RewriteDataFilesAction	set(String property, String value)

Methods inherited from class org.apache.iceberg.actions.BaseRewriteDataFilesAction

caseSensitive, caseSensitive, encryptionManager, execute, filter, outputSpecId, spec, splitLookback, splitOpenFileCost, table, targetSizeInBytes, useStartingSequenceNumber

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.iceberg.actions.Action

option, options

Constructor Details

RewriteDataFilesAction

public RewriteDataFilesAction(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
 Table table)

Method Details

fileIO

protected FileIO fileIO()

Specified by:

fileIO in class BaseRewriteDataFilesAction<RewriteDataFilesAction>

rewriteDataForTasks

protected List<DataFile> rewriteDataForTasks(List<CombinedScanTask> combinedScanTasks)

Specified by:

rewriteDataForTasks in class BaseRewriteDataFilesAction<RewriteDataFilesAction>

self

protected RewriteDataFilesAction self()

maxParallelism

public RewriteDataFilesAction maxParallelism(int parallelism)

set

public RewriteDataFilesAction set(String property,
 String value)

Specified by:

set in interface SnapshotUpdateAction<ThisT,R>

commit

protected void commit(SnapshotUpdate<?> update)

metadataTableName

protected String metadataTableName(MetadataTableType type)

metadataTableName

protected String metadataTableName(String tableName,
 MetadataTableType type)