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

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

  • Method Details

    • 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.