Class SparkPartitionedWriter

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

    public class SparkPartitionedWriter
    extends PartitionedWriter<org.apache.spark.sql.catalyst.InternalRow>
    • Method Detail

      • partition

        protected PartitionKey partition​(org.apache.spark.sql.catalyst.InternalRow row)
        Description copied from class: PartitionedWriter
        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 PartitionedWriter<org.apache.spark.sql.catalyst.InternalRow>
        Parameters:
        row - a data row