storm.trident
Class Stream

java.lang.Object
  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