static List<String> |
TupleStream.getShards(String zkHost,
String collection,
StreamContext streamContext) |
static List<String> |
TupleStream.getShards(String zkHost,
String collection,
StreamContext streamContext,
SolrParams requestParams) |
void |
ZplotStream.setStreamContext(StreamContext context) |
void |
CartesianProductStream.setStreamContext(StreamContext context) |
void |
Facet2DStream.setStreamContext(StreamContext context) |
void |
JoinStream.setStreamContext(StreamContext context) |
void |
FacetStream.setStreamContext(StreamContext context) |
void |
DrillStream.setStreamContext(StreamContext streamContext) |
abstract void |
TupleStream.setStreamContext(StreamContext context) |
void |
HavingStream.setStreamContext(StreamContext context) |
void |
RankStream.setStreamContext(StreamContext context) |
void |
TupStream.setStreamContext(StreamContext context) |
void |
SelectStream.setStreamContext(StreamContext context) |
void |
ListStream.setStreamContext(StreamContext context) |
void |
UpdateStream.setStreamContext(StreamContext context) |
void |
SearchFacadeStream.setStreamContext(StreamContext context) |
void |
EvalStream.setStreamContext(StreamContext streamContext) |
void |
NoOpStream.setStreamContext(StreamContext context) |
void |
CellStream.setStreamContext(StreamContext context) |
void |
CsvStream.setStreamContext(StreamContext context) |
void |
MergeStream.setStreamContext(StreamContext context) |
void |
RollupStream.setStreamContext(StreamContext context) |
void |
PriorityStream.setStreamContext(StreamContext streamContext) |
void |
FeaturesSelectionStream.setStreamContext(StreamContext context) |
void |
JDBCStream.setStreamContext(StreamContext context) |
void |
HashRollupStream.setStreamContext(StreamContext context) |
void |
TextLogitStream.setStreamContext(StreamContext context) |
void |
TextLogitStream.TermsStream.setStreamContext(StreamContext context) |
void |
PlotStream.setStreamContext(StreamContext context) |
void |
SqlStream.setStreamContext(StreamContext context) |
void |
NullStream.setStreamContext(StreamContext context) |
void |
RandomFacadeStream.setStreamContext(StreamContext context) |
void |
ParallelStream.setStreamContext(StreamContext streamContext) |
void |
LetStream.setStreamContext(StreamContext context) |
void |
FetchStream.setStreamContext(StreamContext streamContext) |
void |
IntersectStream.setStreamContext(StreamContext context) |
void |
ReducerStream.setStreamContext(StreamContext context) |
void |
ParallelListStream.setStreamContext(StreamContext context) |
void |
CalculatorStream.setStreamContext(StreamContext context) |
void |
DaemonStream.setStreamContext(StreamContext streamContext) |
void |
UniqueStream.setStreamContext(StreamContext context) |
void |
SortStream.setStreamContext(StreamContext context) |
void |
StatsStream.setStreamContext(StreamContext context) |
void |
ComplementStream.setStreamContext(StreamContext context) |
void |
GetStream.setStreamContext(StreamContext context) |
void |
EchoStream.setStreamContext(StreamContext context) |
void |
HashJoinStream.setStreamContext(StreamContext context) |
void |
SearchStream.setStreamContext(StreamContext context) |
void |
DeepRandomStream.setStreamContext(StreamContext context) |
void |
TimeSeriesStream.setStreamContext(StreamContext context) |
void |
SolrStream.setStreamContext(StreamContext context) |
void |
ScoreNodesStream.setStreamContext(StreamContext context) |
void |
ExceptionStream.setStreamContext(StreamContext context) |
void |
KnnStream.setStreamContext(StreamContext context) |
void |
CommitStream.setStreamContext(StreamContext context) |
void |
RandomStream.setStreamContext(StreamContext context) |
void |
CloudSolrStream.setStreamContext(StreamContext context) |
void |
SignificantTermsStream.setStreamContext(StreamContext context) |
void |
ExecutorStream.setStreamContext(StreamContext streamContext) |
void |
PushBackStream.setStreamContext(StreamContext context) |
void |
ModelStream.setStreamContext(StreamContext context) |