Package org.apache.iceberg.flink.source
Class RowDataRewriter.RewriteMap
- java.lang.Object
-
- org.apache.flink.api.common.functions.AbstractRichFunction
-
- org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,java.util.List<DataFile>>
-
- org.apache.iceberg.flink.source.RowDataRewriter.RewriteMap
-
- All Implemented Interfaces:
java.io.Serializable
,org.apache.flink.api.common.functions.Function
,org.apache.flink.api.common.functions.MapFunction<CombinedScanTask,java.util.List<DataFile>>
,org.apache.flink.api.common.functions.RichFunction
- Enclosing class:
- RowDataRewriter
public static class RowDataRewriter.RewriteMap extends org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,java.util.List<DataFile>>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description RewriteMap(Schema schema, java.lang.String nameMapping, FileIO io, boolean caseSensitive, EncryptionManager encryptionManager, TaskWriterFactory<org.apache.flink.table.data.RowData> taskWriterFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<DataFile>
map(CombinedScanTask task)
void
open(org.apache.flink.configuration.Configuration parameters)
-
-
-
Constructor Detail
-
RewriteMap
public RewriteMap(Schema schema, java.lang.String nameMapping, FileIO io, boolean caseSensitive, EncryptionManager encryptionManager, TaskWriterFactory<org.apache.flink.table.data.RowData> taskWriterFactory)
-
-
Method Detail
-
open
public void open(org.apache.flink.configuration.Configuration parameters)
- Specified by:
open
in interfaceorg.apache.flink.api.common.functions.RichFunction
- Overrides:
open
in classorg.apache.flink.api.common.functions.AbstractRichFunction
-
map
public java.util.List<DataFile> map(CombinedScanTask task) throws java.lang.Exception
- Specified by:
map
in interfaceorg.apache.flink.api.common.functions.MapFunction<CombinedScanTask,java.util.List<DataFile>>
- Specified by:
map
in classorg.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,java.util.List<DataFile>>
- Throws:
java.lang.Exception
-
-