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,List<DataFile>>

org.apache.iceberg.flink.source.RowDataRewriter.RewriteMap

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<CombinedScanTask,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,List<DataFile>>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RewriteMap(Schema schema, String nameMapping, FileIO io, boolean caseSensitive, EncryptionManager encryptionManager, TaskWriterFactory<org.apache.flink.table.data.RowData> taskWriterFactory)

Method Summary

Modifier and Type	Method	Description
List<DataFile>	map(CombinedScanTask task)
void	open(org.apache.flink.api.common.functions.OpenContext parameters)

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Details

RewriteMap

public RewriteMap(Schema schema,
 String nameMapping,
 FileIO io,
 boolean caseSensitive,
 EncryptionManager encryptionManager,
 TaskWriterFactory<org.apache.flink.table.data.RowData> taskWriterFactory)

Method Details

open

public void open(org.apache.flink.api.common.functions.OpenContext parameters)

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

map

public List<DataFile> map(CombinedScanTask task)
                   throws Exception

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<CombinedScanTask,List<DataFile>>

Specified by:

map in class org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,List<DataFile>>

Throws:

Exception