Class SparkPartitionedFanoutWriter

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, TaskWriter<org.apache.spark.sql.catalyst.InternalRow>

    public class SparkPartitionedFanoutWriter
    extends PartitionedFanoutWriter<org.apache.spark.sql.catalyst.InternalRow>
    • Method Detail

      • partition

        protected PartitionKey partition​(org.apache.spark.sql.catalyst.InternalRow row)
        Description copied from class: PartitionedFanoutWriter
        Create a PartitionKey from the values in row.

        Any PartitionKey returned by this method can be reused by the implementation.

        Specified by:
        partition in class PartitionedFanoutWriter<org.apache.spark.sql.catalyst.InternalRow>
        Parameters:
        row - a data row