public class RowDataRewriter
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
RowDataRewriter.RewriteMap |
Constructor and Description |
---|
RowDataRewriter(Table table,
boolean caseSensitive,
FileIO io,
EncryptionManager encryptionManager) |
Modifier and Type | Method and Description |
---|---|
java.util.List<DataFile> |
rewriteDataForTasks(org.apache.flink.streaming.api.datastream.DataStream<CombinedScanTask> dataStream,
int parallelism) |
public RowDataRewriter(Table table, boolean caseSensitive, FileIO io, EncryptionManager encryptionManager)
public java.util.List<DataFile> rewriteDataForTasks(org.apache.flink.streaming.api.datastream.DataStream<CombinedScanTask> dataStream, int parallelism) throws java.lang.Exception
java.lang.Exception