Package org.apache.storm.trident
Class TridentTopology
java.lang.Object
org.apache.storm.trident.TridentTopology
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Streamprotected StreamaddSourcedNode(List<Stream> sources, Node newNode) protected StreamaddSourcedNode(Stream source, Node newNode) protected TridentStateaddSourcedStateNode(List<Stream> sources, Node newNode) protected TridentStateaddSourcedStateNode(Stream source, Node newNode) build()protected Stringprotected Stringprotected Stringjoin(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode) join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type, JoinOutFieldsMode mode) join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed) join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode) join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinOutFieldsMode mode) join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinType type, JoinOutFieldsMode mode) multiReduce(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields) multiReduce(List<Stream> streams, MultiReducer function, Fields outputFields) multiReduce(List<Fields> inputFields, List<GroupedStream> groupedStreams, GroupedMultiReducer function, Fields outputFields) multiReduce(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields) multiReduce(GroupedStream s1, GroupedStream s2, GroupedMultiReducer function, Fields outputFields) multiReduce(Stream s1, Stream s2, MultiReducer function, Fields outputFields) multiReduce(Fields inputFields1, GroupedStream s1, Fields inputFields2, GroupedStream s2, GroupedMultiReducer function, Fields outputFields) multiReduce(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields) newDRPCStream(String function) newDRPCStream(String function, ILocalDRPC server) newStaticState(StateFactory factory) newStaticState(StateSpec spec) newStream(String txId, IRichSpout spout) newStream(String txId, IBatchSpout spout) newStream(String txId, IOpaquePartitionedTridentSpout spout) newStream(String txId, IPartitionedTridentSpout spout) newStream(String txId, ITridentDataSource dataSource) newStream(String txId, ITridentSpout spout) protected voidregisterNode(Node n) protected voidregisterSourcedNode(List<Stream> sources, Node newNode) setMasterCoordResources(DefaultResourceDeclarer resources) setResourceDefaults(DefaultResourceDeclarer defaults)
-
Constructor Details
-
TridentTopology
public TridentTopology()
-
-
Method Details
-
newStream
-
newStream
-
newStream
-
newStream
-
newStream
-
newStream
-
newDRPCStream
-
newDRPCStream
-
newStaticState
-
newStaticState
-
multiReduce
-
multiReduce
-
multiReduce
public Stream multiReduce(GroupedStream s1, GroupedStream s2, GroupedMultiReducer function, Fields outputFields) -
multiReduce
public Stream multiReduce(Fields inputFields1, GroupedStream s1, Fields inputFields2, GroupedStream s2, GroupedMultiReducer function, Fields outputFields) -
multiReduce
-
multiReduce
public Stream multiReduce(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields) -
multiReduce
-
multiReduce
public Stream multiReduce(List<Fields> inputFields, List<GroupedStream> groupedStreams, GroupedMultiReducer function, Fields outputFields) -
merge
-
merge
-
merge
-
merge
-
join
-
join
-
join
-
join
-
join
-
join
-
join
-
join
-
join
-
join
-
join
-
join
-
setResourceDefaults
-
setMasterCoordResources
-
build
-
getUniqueStreamId
-
getUniqueStateId
-
getUniqueWindowId
-
registerNode
-
addNode
-
registerSourcedNode
-
addSourcedNode
-
addSourcedNode
-
addSourcedStateNode
-
addSourcedStateNode
-