storm.trident
Class Stream
java.lang.Object
storm.trident.Stream
- All Implemented Interfaces:
- IAggregatableStream
public class Stream
- extends java.lang.Object
- implements IAggregatableStream
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 |
Stream
protected Stream(TridentTopology topology,
Node node)
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