public class Stream extends Object implements IAggregatableStream
Modifier | Constructor and Description |
---|---|
protected |
Stream(TridentTopology topology,
String name,
Node node) |
protected Stream(TridentTopology topology, String name, Node node)
public Stream parallelismHint(int hint)
public GroupedStream groupBy(Fields fields)
public Stream partition(CustomStreamGrouping partitioner)
public Stream shuffle()
public Stream localOrShuffle()
public Stream global()
public Stream batchGlobal()
public Stream broadcast()
public Stream identityPartition()
public Stream each(Fields inputFields, Function function, Fields functionFields)
each
in interface IAggregatableStream
public Stream partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
partitionAggregate
in interface IAggregatableStream
public Stream stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
public TridentState partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater, Fields functionFields)
public TridentState partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater, Fields functionFields)
public TridentState partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater)
public TridentState partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater)
public ChainedAggregatorDeclarer chainedAgg()
public Stream partitionAggregate(Aggregator agg, Fields functionFields)
public Stream partitionAggregate(CombinerAggregator agg, Fields functionFields)
public Stream partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
public Stream partitionAggregate(ReducerAggregator agg, Fields functionFields)
public Stream partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
public Stream aggregate(Aggregator agg, Fields functionFields)
public Stream aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
public Stream aggregate(CombinerAggregator agg, Fields functionFields)
public Stream aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
public Stream aggregate(ReducerAggregator agg, Fields functionFields)
public Stream aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
public TridentState partitionPersist(StateFactory stateFactory, StateUpdater updater, Fields functionFields)
public TridentState partitionPersist(StateSpec stateSpec, StateUpdater updater, Fields functionFields)
public TridentState partitionPersist(StateFactory stateFactory, StateUpdater updater)
public TridentState partitionPersist(StateSpec stateSpec, StateUpdater updater)
public TridentState persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
public TridentState persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields)
public TridentState persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields)
public TridentState persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
public TridentState persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)
public TridentState persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)
public Stream stateQuery(TridentState state, QueryFunction function, Fields functionFields)
public Stream toStream()
toStream
in interface IAggregatableStream
public Fields getOutputFields()
getOutputFields
in interface IAggregatableStream
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.