Package org.apache.iceberg.flink.maintenance.api

Class RewriteDataFiles

java.lang.Object

org.apache.iceberg.flink.maintenance.api.RewriteDataFiles

public class RewriteDataFiles
extends Object

Creates the data file rewriter data stream. Which runs a single iteration of the task for every Trigger event.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RewriteDataFiles.Builder

Method Summary

Modifier and Type	Method	Description
static RewriteDataFiles.Builder	builder()	Creates the builder for a stream which rewrites data files for the table.

Methods inherited from class java.lang.Object

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

Method Details

builder

public static RewriteDataFiles.Builder builder()

Creates the builder for a stream which rewrites data files for the table.