public static class RowDataRewriter.RewriteMap extends org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,java.util.List<DataFile>>
Constructor and Description |
---|
RewriteMap(Schema schema,
java.lang.String nameMapping,
FileIO io,
boolean caseSensitive,
EncryptionManager encryptionManager,
TaskWriterFactory<org.apache.flink.table.data.RowData> taskWriterFactory) |
Modifier and Type | Method and Description |
---|---|
java.util.List<DataFile> |
map(CombinedScanTask task) |
void |
open(org.apache.flink.configuration.Configuration parameters) |
public RewriteMap(Schema schema, java.lang.String nameMapping, FileIO io, boolean caseSensitive, EncryptionManager encryptionManager, TaskWriterFactory<org.apache.flink.table.data.RowData> taskWriterFactory)
public void open(org.apache.flink.configuration.Configuration parameters)
open
in interface org.apache.flink.api.common.functions.RichFunction
open
in class org.apache.flink.api.common.functions.AbstractRichFunction
public java.util.List<DataFile> map(CombinedScanTask task) throws java.lang.Exception
map
in interface org.apache.flink.api.common.functions.MapFunction<CombinedScanTask,java.util.List<DataFile>>
map
in class org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,java.util.List<DataFile>>
java.lang.Exception