Class NonSerializedPartition<K>

  • Type Parameters:
    K - the key type of its partitions.
    All Implemented Interfaces:
    Partition<java.lang.Iterable,​K>

    public final class NonSerializedPartition<K>
    extends java.lang.Object
    implements Partition<java.lang.Iterable,​K>
    A collection of data elements. The data is stored as an iterable of elements. This is a unit of read / write towards Blocks.
    • Constructor Detail

      • NonSerializedPartition

        public NonSerializedPartition​(K key)
        Creates a non-serialized Partition without actual data. Data can be written to this partition until it is committed.
        Parameters:
        key - the key of this partition.
      • NonSerializedPartition

        public NonSerializedPartition​(K key,
                                      java.util.List data,
                                      long numSerializedBytes,
                                      long numEncodedBytes)
        Creates a non-serialized Partition with actual data. Data cannot be written to this partition after the construction.
        Parameters:
        key - the key.
        data - the non-serialized data.
        numSerializedBytes - the number of bytes in serialized form (which is, for example, encoded and compressed)
        numEncodedBytes - the number of bytes in encoded form (which is ready to be decoded)