Stream (storm-core-java-api 0.11.0 API)

java.lang.Object
- storm.trident.Stream

All Implemented Interfaces:: IAggregatableStream

public class Stream
extends Object
implements IAggregatableStream

Constructor Summary

Constructors
Modifier Constructor and Description

protected Stream(TridentTopology topology, String name, Node node)

Constructors
Modifier	Constructor and Description
`protected`	`Stream(TridentTopology topology, String name, Node node)`

Method Summary

Methods
Modifier and Type	Method and Description
`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`	`localOrShuffle()`
`Stream`	`name(String name)`
`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,
      String name,
      Node node)

Method Detail

name
```
public Stream name(String name)
```

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()
```

localOrShuffle
```
public Stream localOrShuffle()
```

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

Class Stream

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Stream

Method Detail

name

parallelismHint

project

groupBy

partitionBy

partition

shuffle

localOrShuffle

global

batchGlobal

broadcast

identityPartition

partition

applyAssembly

each

partitionAggregate

stateQuery

partitionPersist

partitionPersist

partitionPersist

partitionPersist

each

each

chainedAgg

partitionAggregate

partitionAggregate

partitionAggregate

partitionAggregate

partitionAggregate

aggregate

aggregate

aggregate

aggregate

aggregate

aggregate

partitionPersist

partitionPersist

partitionPersist

partitionPersist

persistentAggregate

persistentAggregate

persistentAggregate

persistentAggregate

persistentAggregate

persistentAggregate

persistentAggregate

persistentAggregate

stateQuery

toStream

getOutputFields