Class PartitionedWriter<T>

    • Method Detail

      • partition

        protected abstract PartitionKey partition​(T row)
        Create a PartitionKey from the values in row.

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

        Parameters:
        row - a data row
      • write

        public void write​(T row)
                   throws java.io.IOException
        Description copied from interface: TaskWriter
        Write the row into the data files.
        Throws:
        java.io.IOException
      • close

        public void close()
                   throws java.io.IOException
        Throws:
        java.io.IOException