Package org.apache.solr.client.solrj.io.stream

Class StreamContext

java.lang.Object
org.apache.solr.client.solrj.io.stream.StreamContext
public class StreamContext extends Object
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.

  • Field Details

    • workerID

      public int workerID

    • numWorkers

      public int numWorkers

  • Constructor Details

    • StreamContext

      public StreamContext()

  • Method Details

    • getObjectCache

      public ConcurrentMap<String,ConcurrentMap<String,Object>> getObjectCache()

    • setObjectCache

      public void setObjectCache(ConcurrentMap<String,ConcurrentMap<String,Object>> objectCache)

    • getLets

      public Map<String,Object> getLets()

    • get

      public Object get(Object key)

    • put

      public void put(String key, Object value)

    • containsKey

      public boolean containsKey(Object key)

    • getEntries

      public Map<String,Object> getEntries()

    • setSolrClientCache

      public void setSolrClientCache(SolrClientCache clientCache)

    • setModelCache

      public void setModelCache(ModelCache modelCache)

    • getSolrClientCache

      public SolrClientCache getSolrClientCache()

    • getModelCache

      public ModelCache getModelCache()

    • setStreamFactory

      public void setStreamFactory(StreamFactory streamFactory)

    • getTupleContext

      public Map<String,String> getTupleContext()

    • getStreamFactory

      public StreamFactory getStreamFactory()

    • setLocal

      public void setLocal(boolean local)

    • isLocal

      public boolean isLocal()

    • setRequestParams

      public void setRequestParams(org.apache.solr.common.params.SolrParams requestParams)

    • getRequestParams

      public org.apache.solr.common.params.SolrParams getRequestParams()

    • setRequestReplicaListTransformerGenerator

      public void setRequestReplicaListTransformerGenerator(org.apache.solr.client.solrj.routing.RequestReplicaListTransformerGenerator requestReplicaListTransformerGenerator)

    • getRequestReplicaListTransformerGenerator

      public org.apache.solr.client.solrj.routing.RequestReplicaListTransformerGenerator getRequestReplicaListTransformerGenerator()