Class StreamContext

  • All Implemented Interfaces:
    Serializable

    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()