storm.trident
Class TridentTopology

java.lang.Object
  extended by storm.trident.TridentTopology

public class TridentTopology
extends java.lang.Object


Constructor Summary
TridentTopology()
           
 
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
 

Constructor Detail

TridentTopology

public TridentTopology()
Method Detail

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)