BiJoinStream(StreamExpression expression,
StreamFactory factory) |
CloudSolrStream(StreamExpression expression,
StreamFactory factory) |
CommitStream(StreamExpression expression,
StreamFactory factory) |
ComplementStream(StreamExpression expression,
StreamFactory factory) |
DaemonStream(StreamExpression expression,
StreamFactory factory) |
ExecutorStream(StreamExpression expression,
StreamFactory factory) |
FacetStream(StreamExpression expression,
StreamFactory factory) |
FeaturesSelectionStream(StreamExpression expression,
StreamFactory factory)
logit(collection, zkHost="", features="a,b,c,d,e,f,g", outcome="y", maxIteration="20")
|
FetchStream(StreamExpression expression,
StreamFactory factory) |
HashJoinStream(StreamExpression expression,
StreamFactory factory) |
HavingStream(StreamExpression expression,
StreamFactory factory) |
InnerJoinStream(StreamExpression expression,
StreamFactory factory) |
IntersectStream(StreamExpression expression,
StreamFactory factory) |
JDBCStream(StreamExpression expression,
StreamFactory factory) |
JoinStream(StreamExpression expression,
StreamFactory factory) |
LeftOuterJoinStream(StreamExpression expression,
StreamFactory factory) |
MergeStream(StreamExpression expression,
StreamFactory factory) |
ModelStream(StreamExpression expression,
StreamFactory factory) |
NullStream(StreamExpression expression,
StreamFactory factory) |
OuterHashJoinStream(StreamExpression expression,
StreamFactory factory) |
ParallelStream(StreamExpression expression,
StreamFactory factory) |
PriorityStream(StreamExpression expression,
StreamFactory factory) |
RandomStream(StreamExpression expression,
StreamFactory factory) |
RankStream(StreamExpression expression,
StreamFactory factory) |
ReducerStream(StreamExpression expression,
StreamFactory factory) |
RollupStream(StreamExpression expression,
StreamFactory factory) |
ScoreNodesStream(StreamExpression expression,
StreamFactory factory) |
SelectStream(StreamExpression expression,
StreamFactory factory) |
SortStream(StreamExpression expression,
StreamFactory factory) |
StatsStream(StreamExpression expression,
StreamFactory factory) |
TextLogitStream(StreamExpression expression,
StreamFactory factory)
logit(collection, zkHost="", features="a,b,c,d,e,f,g", outcome="y", maxIteration="20")
|
TopicStream(StreamExpression expression,
StreamFactory factory) |
UniqueStream(StreamExpression expression,
StreamFactory factory) |
UpdateStream(StreamExpression expression,
StreamFactory factory) |