Class RowDataRewriter

  • All Implemented Interfaces:
    java.io.Serializable

    public class RowDataRewriter
    extends java.lang.Object
    implements java.io.Serializable
    See Also:
    Serialized Form
    • Constructor Detail

      • RowDataRewriter

        public RowDataRewriter​(org.apache.spark.broadcast.Broadcast<Table> tableBroadcast,
                               PartitionSpec spec,
                               boolean caseSensitive)
    • Method Detail

      • rewriteDataForTasks

        public java.util.List<DataFile> rewriteDataForTasks​(org.apache.spark.api.java.JavaRDD<CombinedScanTask> taskRDD)