Package org.apache.storm.trident.fluent
Interface IAggregatableStream
-
- All Known Implementing Classes:
GroupedStream
,Stream
public interface IAggregatableStream
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description IAggregatableStream
each(Fields inputFields, Function function, Fields functionFields)
Fields
getOutputFields()
IAggregatableStream
partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
Stream
toStream()
-
-
-
Method Detail
-
each
IAggregatableStream each(Fields inputFields, Function function, Fields functionFields)
-
partitionAggregate
IAggregatableStream partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
-
toStream
Stream toStream()
-
getOutputFields
Fields getOutputFields()
-
-