Class CassandraIncomingFile

  • All Implemented Interfaces:
    IncomingStream

    public class CassandraIncomingFile
    extends java.lang.Object
    implements IncomingStream
    used to receive the part(or whole) of a SSTable data file. This class deserializes the data stream into partitions and rows, and writes that out as an sstable