Package org.apache.iceberg.flink.source

Class RowDataRewriter

java.lang.Object

org.apache.iceberg.flink.source.RowDataRewriter

public class RowDataRewriter
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RowDataRewriter.RewriteMap

Constructor Summary

Constructors

Constructor	Description
RowDataRewriter(Table table, boolean caseSensitive, FileIO io, EncryptionManager encryptionManager)

Method Summary

Modifier and Type	Method	Description
List<DataFile>	rewriteDataForTasks(org.apache.flink.streaming.api.datastream.DataStream<CombinedScanTask> dataStream, int parallelism)

Methods inherited from class java.lang.Object

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

Constructor Details

RowDataRewriter

public RowDataRewriter(Table table,
 boolean caseSensitive,
 FileIO io,
 EncryptionManager encryptionManager)

Method Details

rewriteDataForTasks

public List<DataFile> rewriteDataForTasks(org.apache.flink.streaming.api.datastream.DataStream<CombinedScanTask> dataStream,
 int parallelism)
                                   throws Exception

Throws:

Exception