Class 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
    • 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)  
      • 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 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 interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        open in class org.apache.flink.api.common.functions.AbstractRichFunction
      • map

        public java.util.List<DataFile> map​(CombinedScanTask task)
                                     throws java.lang.Exception
        Specified by:
        map in interface org.apache.flink.api.common.functions.MapFunction<CombinedScanTask,​java.util.List<DataFile>>
        Specified by:
        map in class org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,​java.util.List<DataFile>>
        Throws:
        java.lang.Exception