Interface Partition<T,​K>

    • Method Detail

      • write

        void write​(Object element)
            throws IOException
        Writes an element to non-committed partition.
        Parameters:
        element - element to write.
        Throws:
        IOException - if the partition is already committed.
      • commit

        void commit()
             throws IOException
        Commits a partition to prevent further data write.
        Throws:
        IOException - if fail to commit partition.
      • getKey

        K getKey()
        Returns:
        the key value.
      • isSerialized

        boolean isSerialized()
        Returns:
        whether the data in this Partition is serialized or not.