Package | Description |
---|---|
org.apache.solr.client.solrj.io.ops |
Operations for the Streaming Aggregation API
|
org.apache.solr.client.solrj.io.stream |
Stream implementations for the Streaming Aggregation API
|
org.apache.solr.client.solrj.io.stream.expr |
Expression language for the Streaming Aggregation API
|
org.apache.solr.client.solrj.io.stream.metrics |
Metrics package
|
Constructor and Description |
---|
ConcatOperation(StreamExpression expression,
StreamFactory factory) |
DistinctOperation(StreamExpression expression,
StreamFactory factory) |
GroupOperation(StreamExpression expression,
StreamFactory factory) |
ReplaceOperation(StreamExpression expression,
StreamFactory factory) |
ReplaceOperation(String forField,
StreamExpression expression,
StreamFactory factory) |
ReplaceWithFieldOperation(String forField,
StreamExpression expression,
StreamFactory factory) |
ReplaceWithValueOperation(String forField,
StreamExpression expression,
StreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
StreamExpression |
JoinStream.toExpression(StreamFactory factory) |
StreamExpression |
ParallelStream.toExpression(StreamFactory factory) |
StreamExpression |
ComplementStream.toExpression(StreamFactory factory) |
StreamExpression |
IntersectStream.toExpression(StreamFactory factory) |
StreamExpression |
SelectStream.toExpression(StreamFactory factory) |
StreamExpression |
UniqueStream.toExpression(StreamFactory factory) |
StreamExpression |
OuterHashJoinStream.toExpression(StreamFactory factory) |
StreamExpression |
ReducerStream.toExpression(StreamFactory factory) |
StreamExpression |
HashJoinStream.toExpression(StreamFactory factory) |
StreamExpression |
MergeStream.toExpression(StreamFactory factory) |
StreamExpression |
RankStream.toExpression(StreamFactory factory) |
StreamExpression |
DaemonStream.toExpression(StreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
static StreamExpression |
StreamExpressionParser.parse(String clause) |
StreamExpression |
StreamExpression.withFunctionName(String functionName) |
StreamExpression |
StreamExpression.withParameter(StreamExpressionParameter parameter) |
StreamExpression |
StreamExpression.withParameter(String parameter) |
StreamExpression |
StreamExpression.withParameters(List<StreamExpressionParameter> parameters) |
Modifier and Type | Method and Description |
---|---|
List<StreamExpression> |
StreamFactory.getExpressionOperands(StreamExpression expression) |
List<StreamExpression> |
StreamFactory.getExpressionOperands(StreamExpression expression,
String functionName) |
List<StreamExpression> |
StreamFactory.getExpressionOperandsRepresentingTypes(StreamExpression expression,
Class... clazzes) |
Constructor and Description |
---|
CountMetric(StreamExpression expression,
StreamFactory factory) |
MaxMetric(StreamExpression expression,
StreamFactory factory) |
MeanMetric(StreamExpression expression,
StreamFactory factory) |
MinMetric(StreamExpression expression,
StreamFactory factory) |
SumMetric(StreamExpression expression,
StreamFactory factory) |
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.