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