Package | Description |
---|---|
storm.trident | |
storm.trident.fluent | |
storm.trident.operation | |
storm.trident.operation.builtin | |
storm.trident.operation.impl | |
storm.trident.planner.processor | |
storm.trident.testing |
Modifier and Type | Method and Description |
---|---|
Stream |
Stream.aggregate(Aggregator agg,
Fields functionFields) |
Stream |
Stream.aggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
Stream |
Stream.partitionAggregate(Aggregator agg,
Fields functionFields) |
Stream |
Stream.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
Modifier and Type | Method and Description |
---|---|
Stream |
GroupedStream.aggregate(Aggregator agg,
Fields functionFields) |
ChainedFullAggregatorDeclarer |
ChainedFullAggregatorDeclarer.aggregate(Aggregator agg,
Fields functionFields) |
ChainedFullAggregatorDeclarer |
ChainedAggregatorDeclarer.aggregate(Aggregator agg,
Fields functionFields) |
Stream |
GroupedStream.aggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
ChainedFullAggregatorDeclarer |
ChainedFullAggregatorDeclarer.aggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
ChainedFullAggregatorDeclarer |
ChainedAggregatorDeclarer.aggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
ChainedPartitionAggregatorDeclarer |
ChainedPartitionAggregatorDeclarer.partitionAggregate(Aggregator agg,
Fields functionFields) |
ChainedPartitionAggregatorDeclarer |
ChainedAggregatorDeclarer.partitionAggregate(Aggregator agg,
Fields functionFields) |
IAggregatableStream |
IAggregatableStream.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
IAggregatableStream |
GroupedStream.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
ChainedPartitionAggregatorDeclarer |
ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
ChainedPartitionAggregatorDeclarer |
ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
Modifier and Type | Class and Description |
---|---|
class |
BaseAggregator<T> |
Modifier and Type | Class and Description |
---|---|
static class |
FirstN.FirstNAgg |
static class |
FirstN.FirstNSortedAgg |
Modifier and Type | Class and Description |
---|---|
class |
ChainedAggregatorImpl |
class |
CombinerAggregatorCombineImpl |
class |
GroupedAggregator |
class |
ReducerAggregatorImpl |
class |
SingleEmitAggregator |
Constructor and Description |
---|
ChainedAggregatorImpl(Aggregator[] aggs,
Fields[] inputFields,
ComboList.Factory fact) |
GroupedAggregator(Aggregator agg,
Fields group,
Fields input,
int outSize) |
SingleEmitAggregator(Aggregator agg,
SingleEmitAggregator.BatchToPartition batchToPartition) |
Constructor and Description |
---|
AggregateProcessor(Fields inputFields,
Aggregator agg) |
Modifier and Type | Class and Description |
---|---|
class |
CountAsAggregator |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.