storm.trident.fluent

Interface IAggregatableStream

All Known Implementing Classes:

GroupedStream, Stream

public interface IAggregatableStream

Method Summary

Modifier and Type	Method and 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()