Package com.qfs.msg

Interface IMessageChunk<E>

  • Type Parameters:
    E - type of the data elements appended to the chunk
    All Known Subinterfaces:
    IStoreMessageChunk<E>
    All Known Implementing Classes:
    TupleMessageChunk
    public interface IMessageChunk<E>
    A chunk of data within a message. When data is loaded from a data source, the data transfer usually happens one block of data at a time. The message chunk is the abstraction for that.

    A source that reads files will typically send one message per file, but split the bytes of the file into chunks to be parsed.

    For example, a source that reads data from a relational database, by executing a SQL query for instance, will fetch the possibly large result set block by block, sending one message chunk for each block.

    The message chunk is filled incrementally as data elements are appended to the chunk in sequence.

    Author:
    ActiveViam

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      boolean append​(E data)
      Append a piece of data produced by the source into this message chunk.

    • Method Detail

      • append

        boolean append​(E data)
        Append a piece of data produced by the source into this message chunk.
        Parameters:
        data - piece of data produced by the source
        Returns:
        true if the data was actually appended to the message chunk or false if it was discarded for whatever reason.