Package | Description |
---|---|
storm.trident | |
storm.trident.fluent |
Modifier and Type | Class and Description |
---|---|
class |
Stream |
Modifier and Type | Interface and Description |
---|---|
interface |
GlobalAggregationScheme<S extends IAggregatableStream> |
Modifier and Type | Class and Description |
---|---|
class |
GroupedStream |
Modifier and Type | Method and Description |
---|---|
IAggregatableStream |
GroupedStream.aggPartition(GroupedStream s) |
IAggregatableStream |
GlobalAggregationScheme.aggPartition(S stream) |
IAggregatableStream |
IAggregatableStream.each(Fields inputFields,
Function function,
Fields functionFields) |
IAggregatableStream |
GroupedStream.each(Fields inputFields,
Function function,
Fields functionFields) |
IAggregatableStream |
IAggregatableStream.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
IAggregatableStream |
GroupedStream.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
Constructor and Description |
---|
ChainedAggregatorDeclarer(IAggregatableStream stream,
GlobalAggregationScheme globalScheme) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.