Class StreamContext

  • All Implemented Interfaces:

    public class StreamContext
    extends Object
    implements Serializable
    The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method. The StreamContext is used to pass shared context to concentrically wrapped TupleStreams. Note: The StreamContext contains the SolrClientCache which is used to cache SolrClients for reuse across multiple TupleStreams.
    See Also:
    Serialized Form
    • Field Detail

      • workerID

        public int workerID
      • numWorkers

        public int numWorkers
    • Constructor Detail

      • StreamContext

        public StreamContext()