storm.trident
Class TridentTopology
java.lang.Object
storm.trident.TridentTopology
public class TridentTopology
- extends java.lang.Object
Method Summary |
protected Stream |
addNode(Node n)
|
protected Stream |
addSourcedNode(java.util.List<Stream> sources,
Node newNode)
|
protected Stream |
addSourcedNode(Stream source,
Node newNode)
|
protected TridentState |
addSourcedStateNode(java.util.List<Stream> sources,
Node newNode)
|
protected TridentState |
addSourcedStateNode(Stream source,
Node newNode)
|
StormTopology |
build()
|
protected java.lang.String |
getUniqueStateId()
|
protected java.lang.String |
getUniqueStreamId()
|
Stream |
join(java.util.List<Stream> streams,
java.util.List<Fields> joinFields,
Fields outFields)
|
Stream |
join(java.util.List<Stream> streams,
java.util.List<Fields> joinFields,
Fields outFields,
JoinType type)
|
Stream |
join(java.util.List<Stream> streams,
java.util.List<Fields> joinFields,
Fields outFields,
java.util.List<JoinType> mixed)
|
Stream |
join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields)
|
Stream |
join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
JoinType type)
|
Stream |
join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
java.util.List<JoinType> mixed)
|
Stream |
merge(Fields outputFields,
java.util.List<Stream> streams)
|
Stream |
merge(Fields outputFields,
Stream... streams)
|
Stream |
merge(java.util.List<Stream> streams)
|
Stream |
merge(Stream... streams)
|
Stream |
multiReduce(Fields inputFields1,
GroupedStream s1,
Fields inputFields2,
GroupedStream s2,
GroupedMultiReducer function,
Fields outputFields)
|
Stream |
multiReduce(Fields inputFields1,
Stream s1,
Fields inputFields2,
Stream s2,
MultiReducer function,
Fields outputFields)
|
Stream |
multiReduce(GroupedStream s1,
GroupedStream s2,
GroupedMultiReducer function,
Fields outputFields)
|
Stream |
multiReduce(java.util.List<Fields> inputFields,
java.util.List<GroupedStream> groupedStreams,
GroupedMultiReducer function,
Fields outputFields)
|
Stream |
multiReduce(java.util.List<Fields> inputFields,
java.util.List<Stream> streams,
MultiReducer function,
Fields outputFields)
|
Stream |
multiReduce(java.util.List<GroupedStream> streams,
GroupedMultiReducer function,
Fields outputFields)
|
Stream |
multiReduce(java.util.List<Stream> streams,
MultiReducer function,
Fields outputFields)
|
Stream |
multiReduce(Stream s1,
Stream s2,
MultiReducer function,
Fields outputFields)
|
Stream |
newDRPCStream(java.lang.String function)
|
Stream |
newDRPCStream(java.lang.String function,
ILocalDRPC server)
|
TridentState |
newStaticState(StateFactory factory)
|
TridentState |
newStaticState(StateSpec spec)
|
Stream |
newStream(java.lang.String txId,
IBatchSpout spout)
|
Stream |
newStream(java.lang.String txId,
IOpaquePartitionedTridentSpout spout)
|
Stream |
newStream(java.lang.String txId,
IPartitionedTridentSpout spout)
|
Stream |
newStream(java.lang.String txId,
IRichSpout spout)
|
Stream |
newStream(java.lang.String txId,
ITridentSpout spout)
|
protected void |
registerNode(Node n)
|
protected void |
registerSourcedNode(java.util.List<Stream> sources,
Node newNode)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TridentTopology
public TridentTopology()
newStream
public Stream newStream(java.lang.String txId,
IRichSpout spout)
newStream
public Stream newStream(java.lang.String txId,
IBatchSpout spout)
newStream
public Stream newStream(java.lang.String txId,
ITridentSpout spout)
newStream
public Stream newStream(java.lang.String txId,
IPartitionedTridentSpout spout)
newStream
public Stream newStream(java.lang.String txId,
IOpaquePartitionedTridentSpout spout)
newDRPCStream
public Stream newDRPCStream(java.lang.String function)
newDRPCStream
public Stream newDRPCStream(java.lang.String function,
ILocalDRPC server)
newStaticState
public TridentState newStaticState(StateFactory factory)
newStaticState
public TridentState newStaticState(StateSpec spec)
multiReduce
public Stream multiReduce(Stream s1,
Stream s2,
MultiReducer function,
Fields outputFields)
multiReduce
public Stream multiReduce(Fields inputFields1,
Stream s1,
Fields inputFields2,
Stream s2,
MultiReducer function,
Fields outputFields)
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
public Stream multiReduce(java.util.List<Stream> streams,
MultiReducer function,
Fields outputFields)
multiReduce
public Stream multiReduce(java.util.List<GroupedStream> streams,
GroupedMultiReducer function,
Fields outputFields)
multiReduce
public Stream multiReduce(java.util.List<Fields> inputFields,
java.util.List<Stream> streams,
MultiReducer function,
Fields outputFields)
multiReduce
public Stream multiReduce(java.util.List<Fields> inputFields,
java.util.List<GroupedStream> groupedStreams,
GroupedMultiReducer function,
Fields outputFields)
merge
public Stream merge(Fields outputFields,
Stream... streams)
merge
public Stream merge(Fields outputFields,
java.util.List<Stream> streams)
merge
public Stream merge(Stream... streams)
merge
public Stream merge(java.util.List<Stream> streams)
join
public Stream join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields)
join
public Stream join(java.util.List<Stream> streams,
java.util.List<Fields> joinFields,
Fields outFields)
join
public Stream join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
JoinType type)
join
public Stream join(java.util.List<Stream> streams,
java.util.List<Fields> joinFields,
Fields outFields,
JoinType type)
join
public Stream join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
java.util.List<JoinType> mixed)
join
public Stream join(java.util.List<Stream> streams,
java.util.List<Fields> joinFields,
Fields outFields,
java.util.List<JoinType> mixed)
build
public StormTopology build()
getUniqueStreamId
protected java.lang.String getUniqueStreamId()
getUniqueStateId
protected java.lang.String getUniqueStateId()
registerNode
protected void registerNode(Node n)
addNode
protected Stream addNode(Node n)
registerSourcedNode
protected void registerSourcedNode(java.util.List<Stream> sources,
Node newNode)
addSourcedNode
protected Stream addSourcedNode(java.util.List<Stream> sources,
Node newNode)
addSourcedStateNode
protected TridentState addSourcedStateNode(java.util.List<Stream> sources,
Node newNode)
addSourcedNode
protected Stream addSourcedNode(Stream source,
Node newNode)
addSourcedStateNode
protected TridentState addSourcedStateNode(Stream source,
Node newNode)