Package org.apache.iceberg.flink.source
Class RowDataRewriter
- java.lang.Object
-
- org.apache.iceberg.flink.source.RowDataRewriter
-
public class RowDataRewriter extends java.lang.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<DataFile>
rewriteDataForTasks(org.apache.flink.streaming.api.datastream.DataStream<CombinedScanTask> dataStream, int parallelism)
-
-
-
Constructor Detail
-
RowDataRewriter
public RowDataRewriter(Table table, boolean caseSensitive, FileIO io, EncryptionManager encryptionManager)
-
-
Method Detail
-
rewriteDataForTasks
public java.util.List<DataFile> rewriteDataForTasks(org.apache.flink.streaming.api.datastream.DataStream<CombinedScanTask> dataStream, int parallelism) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-