Class RowDataRewriter


  • public class RowDataRewriter
    extends java.lang.Object
    • Constructor Detail

    • Method Detail

      • rewriteDataForTasks

        public java.util.List<DataFile> rewriteDataForTasks​(org.apache.flink.streaming.api.datastream.DataStream<CombinedScanTask> dataStream,
                                                            int parallelism)
                                                     throws java.lang.Exception
        Throws:
        java.lang.Exception