storm.trident
Class Stream

java.lang.Object
  extended by storm.trident.Stream
All Implemented Interfaces:
IAggregatableStream

public class Stream
extends java.lang.Object
implements IAggregatableStream


Constructor Summary
protected Stream(TridentTopology topology, Node node)
           
 
Method Summary
 Stream aggregate(Aggregator agg, Fields functionFields)
           
 Stream aggregate(CombinerAggregator agg, Fields functionFields)
           
 Stream aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
           
 Stream aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
           
 Stream aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
           
 Stream aggregate(ReducerAggregator agg, Fields functionFields)
           
 Stream applyAssembly(Assembly assembly)
           
 Stream batchGlobal()
           
 Stream broadcast()
           
 ChainedAggregatorDeclarer chainedAgg()
           
 Stream each(Fields inputFields, Filter filter)
           
 Stream each(Fields inputFields, Function function, Fields functionFields)
           
 Stream each(Function function, Fields functionFields)
           
 Fields getOutputFields()
           
 Stream global()
           
 GroupedStream groupBy(Fields fields)
           
 Stream identityPartition()
           
 Stream parallelismHint(int hint)
           
 Stream partition(CustomStreamGrouping partitioner)
           
 Stream partition(Grouping grouping)
           
 Stream partitionAggregate(Aggregator agg, Fields functionFields)
           
 Stream partitionAggregate(CombinerAggregator agg, Fields functionFields)
           
 Stream partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
           
 Stream partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
           
 Stream partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
           
 Stream partitionAggregate(ReducerAggregator agg, Fields functionFields)
           
 Stream partitionBy(Fields fields)
           
 TridentState partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater)
           
 TridentState partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater, Fields functionFields)
           
 TridentState partitionPersist(StateFactory stateFactory, StateUpdater updater)
           
 TridentState partitionPersist(StateFactory stateFactory, StateUpdater updater, Fields functionFields)
           
 TridentState partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater)
           
 TridentState partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater, Fields functionFields)
           
 TridentState partitionPersist(StateSpec stateSpec, StateUpdater updater)
           
 TridentState partitionPersist(StateSpec stateSpec, StateUpdater updater, Fields functionFields)
           
 TridentState persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
           
 TridentState persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
           
 TridentState persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
           
 TridentState persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
           
 TridentState persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields)
           
 TridentState persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields)
           
 TridentState persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)
           
 TridentState persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)
           
 Stream project(Fields keepFields)
           
 Stream shuffle()
           
 Stream stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
           
 Stream stateQuery(TridentState state, QueryFunction function, Fields functionFields)
           
 Stream toStream()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Stream

protected Stream(TridentTopology topology,
                 Node node)
Method Detail

parallelismHint

public Stream parallelismHint(int hint)

project

public Stream project(Fields keepFields)

groupBy

public GroupedStream groupBy(Fields fields)

partitionBy

public Stream partitionBy(Fields fields)

partition

public Stream partition(CustomStreamGrouping partitioner)

shuffle

public Stream shuffle()

global

public Stream global()

batchGlobal

public Stream batchGlobal()

broadcast

public Stream broadcast()

identityPartition

public Stream identityPartition()

partition

public Stream partition(Grouping grouping)

applyAssembly

public Stream applyAssembly(Assembly assembly)

each

public Stream each(Fields inputFields,
                   Function function,
                   Fields functionFields)
Specified by:
each in interface IAggregatableStream

partitionAggregate

public Stream partitionAggregate(Fields inputFields,
                                 Aggregator agg,
                                 Fields functionFields)
Specified by:
partitionAggregate in interface IAggregatableStream

stateQuery

public Stream stateQuery(TridentState state,
                         Fields inputFields,
                         QueryFunction function,
                         Fields functionFields)

partitionPersist

public TridentState partitionPersist(StateFactory stateFactory,
                                     Fields inputFields,
                                     StateUpdater updater,
                                     Fields functionFields)

partitionPersist

public TridentState partitionPersist(StateSpec stateSpec,
                                     Fields inputFields,
                                     StateUpdater updater,
                                     Fields functionFields)

partitionPersist

public TridentState partitionPersist(StateFactory stateFactory,
                                     Fields inputFields,
                                     StateUpdater updater)

partitionPersist

public TridentState partitionPersist(StateSpec stateSpec,
                                     Fields inputFields,
                                     StateUpdater updater)

each

public Stream each(Function function,
                   Fields functionFields)

each

public Stream each(Fields inputFields,
                   Filter filter)

chainedAgg

public ChainedAggregatorDeclarer chainedAgg()

partitionAggregate

public Stream partitionAggregate(Aggregator agg,
                                 Fields functionFields)

partitionAggregate

public Stream partitionAggregate(CombinerAggregator agg,
                                 Fields functionFields)

partitionAggregate

public Stream partitionAggregate(Fields inputFields,
                                 CombinerAggregator agg,
                                 Fields functionFields)

partitionAggregate

public Stream partitionAggregate(ReducerAggregator agg,
                                 Fields functionFields)

partitionAggregate

public Stream partitionAggregate(Fields inputFields,
                                 ReducerAggregator agg,
                                 Fields functionFields)

aggregate

public Stream aggregate(Aggregator agg,
                        Fields functionFields)

aggregate

public Stream aggregate(Fields inputFields,
                        Aggregator agg,
                        Fields functionFields)

aggregate

public Stream aggregate(CombinerAggregator agg,
                        Fields functionFields)

aggregate

public Stream aggregate(Fields inputFields,
                        CombinerAggregator agg,
                        Fields functionFields)

aggregate

public Stream aggregate(ReducerAggregator agg,
                        Fields functionFields)

aggregate

public Stream aggregate(Fields inputFields,
                        ReducerAggregator agg,
                        Fields functionFields)

partitionPersist

public TridentState partitionPersist(StateFactory stateFactory,
                                     StateUpdater updater,
                                     Fields functionFields)

partitionPersist

public TridentState partitionPersist(StateSpec stateSpec,
                                     StateUpdater updater,
                                     Fields functionFields)

partitionPersist

public TridentState partitionPersist(StateFactory stateFactory,
                                     StateUpdater updater)

partitionPersist

public TridentState partitionPersist(StateSpec stateSpec,
                                     StateUpdater updater)

persistentAggregate

public TridentState persistentAggregate(StateFactory stateFactory,
                                        CombinerAggregator agg,
                                        Fields functionFields)

persistentAggregate

public TridentState persistentAggregate(StateSpec spec,
                                        CombinerAggregator agg,
                                        Fields functionFields)

persistentAggregate

public TridentState persistentAggregate(StateFactory stateFactory,
                                        Fields inputFields,
                                        CombinerAggregator agg,
                                        Fields functionFields)

persistentAggregate

public TridentState persistentAggregate(StateSpec spec,
                                        Fields inputFields,
                                        CombinerAggregator agg,
                                        Fields functionFields)

persistentAggregate

public TridentState persistentAggregate(StateFactory stateFactory,
                                        ReducerAggregator agg,
                                        Fields functionFields)

persistentAggregate

public TridentState persistentAggregate(StateSpec spec,
                                        ReducerAggregator agg,
                                        Fields functionFields)

persistentAggregate

public TridentState persistentAggregate(StateFactory stateFactory,
                                        Fields inputFields,
                                        ReducerAggregator agg,
                                        Fields functionFields)

persistentAggregate

public TridentState persistentAggregate(StateSpec spec,
                                        Fields inputFields,
                                        ReducerAggregator agg,
                                        Fields functionFields)

stateQuery

public Stream stateQuery(TridentState state,
                         QueryFunction function,
                         Fields functionFields)

toStream

public Stream toStream()
Specified by:
toStream in interface IAggregatableStream

getOutputFields

public Fields getOutputFields()
Specified by:
getOutputFields in interface IAggregatableStream