Package | Description |
---|---|
storm.trident | |
storm.trident.fluent | |
storm.trident.operation | |
storm.trident.operation.builtin |
Modifier and Type | Method and Description |
---|---|
protected Stream |
TridentTopology.addNode(Node n) |
protected Stream |
TridentTopology.addSourcedNode(List<Stream> sources,
Node newNode) |
protected Stream |
TridentTopology.addSourcedNode(Stream source,
Node newNode) |
Stream |
Stream.aggregate(Aggregator agg,
Fields functionFields) |
Stream |
Stream.aggregate(CombinerAggregator agg,
Fields functionFields) |
Stream |
Stream.aggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
Stream |
Stream.aggregate(Fields inputFields,
CombinerAggregator agg,
Fields functionFields) |
Stream |
Stream.aggregate(Fields inputFields,
ReducerAggregator agg,
Fields functionFields) |
Stream |
Stream.aggregate(ReducerAggregator agg,
Fields functionFields) |
Stream |
Stream.applyAssembly(Assembly assembly) |
Stream |
Stream.batchGlobal() |
Stream |
Stream.broadcast() |
Stream |
Stream.each(Fields inputFields,
Filter filter) |
Stream |
Stream.each(Fields inputFields,
Function function,
Fields functionFields) |
Stream |
Stream.each(Function function,
Fields functionFields) |
Stream |
Stream.global() |
Stream |
Stream.identityPartition() |
Stream |
TridentTopology.join(List<Stream> streams,
List<Fields> joinFields,
Fields outFields) |
Stream |
TridentTopology.join(List<Stream> streams,
List<Fields> joinFields,
Fields outFields,
JoinType type) |
Stream |
TridentTopology.join(List<Stream> streams,
List<Fields> joinFields,
Fields outFields,
List<JoinType> mixed) |
Stream |
TridentTopology.join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields) |
Stream |
TridentTopology.join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
JoinType type) |
Stream |
TridentTopology.join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
List<JoinType> mixed) |
Stream |
Stream.localOrShuffle() |
Stream |
TridentTopology.merge(Fields outputFields,
List<Stream> streams) |
Stream |
TridentTopology.merge(Fields outputFields,
Stream... streams) |
Stream |
TridentTopology.merge(List<Stream> streams) |
Stream |
TridentTopology.merge(Stream... streams) |
Stream |
TridentTopology.multiReduce(Fields inputFields1,
GroupedStream s1,
Fields inputFields2,
GroupedStream s2,
GroupedMultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(Fields inputFields1,
Stream s1,
Fields inputFields2,
Stream s2,
MultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(GroupedStream s1,
GroupedStream s2,
GroupedMultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(List<Fields> inputFields,
List<GroupedStream> groupedStreams,
GroupedMultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(List<Fields> inputFields,
List<Stream> streams,
MultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(List<GroupedStream> streams,
GroupedMultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(List<Stream> streams,
MultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(Stream s1,
Stream s2,
MultiReducer function,
Fields outputFields) |
Stream |
Stream.name(String name) |
Stream |
TridentTopology.newDRPCStream(String function) |
Stream |
TridentTopology.newDRPCStream(String function,
ILocalDRPC server) |
Stream |
TridentTopology.newStream(String txId,
IBatchSpout spout) |
Stream |
TridentTopology.newStream(String txId,
IOpaquePartitionedTridentSpout spout) |
Stream |
TridentTopology.newStream(String txId,
IPartitionedTridentSpout spout) |
Stream |
TridentTopology.newStream(String txId,
IRichSpout spout) |
Stream |
TridentTopology.newStream(String txId,
ITridentSpout spout) |
Stream |
TridentState.newValuesStream() |
Stream |
Stream.parallelismHint(int hint) |
Stream |
Stream.partition(CustomStreamGrouping partitioner) |
Stream |
Stream.partition(Grouping grouping) |
Stream |
Stream.partitionAggregate(Aggregator agg,
Fields functionFields) |
Stream |
Stream.partitionAggregate(CombinerAggregator agg,
Fields functionFields) |
Stream |
Stream.partitionAggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
Stream |
Stream.partitionAggregate(Fields inputFields,
CombinerAggregator agg,
Fields functionFields) |
Stream |
Stream.partitionAggregate(Fields inputFields,
ReducerAggregator agg,
Fields functionFields) |
Stream |
Stream.partitionAggregate(ReducerAggregator agg,
Fields functionFields) |
Stream |
Stream.partitionBy(Fields fields) |
Stream |
Stream.project(Fields keepFields) |
Stream |
Stream.shuffle() |
Stream |
Stream.stateQuery(TridentState state,
Fields inputFields,
QueryFunction function,
Fields functionFields) |
Stream |
Stream.stateQuery(TridentState state,
QueryFunction function,
Fields functionFields) |
Stream |
Stream.toStream() |
Modifier and Type | Method and Description |
---|---|
protected Stream |
TridentTopology.addSourcedNode(Stream source,
Node newNode) |
protected TridentState |
TridentTopology.addSourcedStateNode(Stream source,
Node newNode) |
Stream |
TridentTopology.join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields) |
Stream |
TridentTopology.join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
JoinType type) |
Stream |
TridentTopology.join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
List<JoinType> mixed) |
Stream |
TridentTopology.merge(Fields outputFields,
Stream... streams) |
Stream |
TridentTopology.merge(Stream... streams) |
Stream |
TridentTopology.multiReduce(Fields inputFields1,
Stream s1,
Fields inputFields2,
Stream s2,
MultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(Stream s1,
Stream s2,
MultiReducer function,
Fields outputFields) |
Modifier and Type | Method and Description |
---|---|
protected Stream |
TridentTopology.addSourcedNode(List<Stream> sources,
Node newNode) |
protected TridentState |
TridentTopology.addSourcedStateNode(List<Stream> sources,
Node newNode) |
Stream |
TridentTopology.join(List<Stream> streams,
List<Fields> joinFields,
Fields outFields) |
Stream |
TridentTopology.join(List<Stream> streams,
List<Fields> joinFields,
Fields outFields,
JoinType type) |
Stream |
TridentTopology.join(List<Stream> streams,
List<Fields> joinFields,
Fields outFields,
List<JoinType> mixed) |
Stream |
TridentTopology.merge(Fields outputFields,
List<Stream> streams) |
Stream |
TridentTopology.merge(List<Stream> streams) |
Stream |
TridentTopology.multiReduce(List<Fields> inputFields,
List<Stream> streams,
MultiReducer function,
Fields outputFields) |
Stream |
TridentTopology.multiReduce(List<Stream> streams,
MultiReducer function,
Fields outputFields) |
protected void |
TridentTopology.registerSourcedNode(List<Stream> sources,
Node newNode) |
Modifier and Type | Method and Description |
---|---|
Stream |
GroupedStream.aggregate(Aggregator agg,
Fields functionFields) |
Stream |
GroupedStream.aggregate(CombinerAggregator agg,
Fields functionFields) |
Stream |
GroupedStream.aggregate(Fields inputFields,
Aggregator agg,
Fields functionFields) |
Stream |
GroupedStream.aggregate(Fields inputFields,
CombinerAggregator agg,
Fields functionFields) |
Stream |
GroupedStream.aggregate(Fields inputFields,
ReducerAggregator agg,
Fields functionFields) |
Stream |
GroupedStream.aggregate(ReducerAggregator agg,
Fields functionFields) |
Stream |
IChainedAggregatorDeclarer.chainEnd() |
Stream |
ChainedAggregatorDeclarer.chainEnd() |
Stream |
ChainedAggregatorDeclarer.AggregationPartition.partition(Stream input) |
Stream |
GroupedStream.stateQuery(TridentState state,
Fields inputFields,
QueryFunction function,
Fields functionFields) |
Stream |
GroupedStream.stateQuery(TridentState state,
QueryFunction function,
Fields functionFields) |
Stream |
IAggregatableStream.toStream() |
Stream |
GroupedStream.toStream() |
Modifier and Type | Method and Description |
---|---|
Stream |
ChainedAggregatorDeclarer.AggregationPartition.partition(Stream input) |
Constructor and Description |
---|
GroupedStream(Stream stream,
Fields groupFields) |
Modifier and Type | Method and Description |
---|---|
Stream |
Assembly.apply(Stream input) |
Modifier and Type | Method and Description |
---|---|
Stream |
Assembly.apply(Stream input) |
Modifier and Type | Method and Description |
---|---|
Stream |
FirstN.apply(Stream input) |
Modifier and Type | Method and Description |
---|---|
Stream |
FirstN.apply(Stream input) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.