Package | Description |
---|---|
org.apache.storm.trident | |
org.apache.storm.trident.graph | |
org.apache.storm.trident.planner |
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) |
protected TridentState |
TridentTopology.addSourcedStateNode(List<Stream> sources,
Node newNode) |
protected TridentState |
TridentTopology.addSourcedStateNode(Stream source,
Node newNode) |
protected void |
TridentTopology.registerNode(Node n) |
protected void |
TridentTopology.registerSourcedNode(List<Stream> sources,
Node newNode) |
Constructor and Description |
---|
Stream(TridentTopology topology,
String name,
Node node) |
TridentState(TridentTopology topology,
Node node) |
Modifier and Type | Field and Description |
---|---|
Set<Node> |
Group.nodes |
Modifier and Type | Method and Description |
---|---|
Set<Node> |
Group.incomingNodes() |
Set<Node> |
Group.outgoingNodes() |
Modifier and Type | Method and Description |
---|---|
Group |
GraphGrouper.nodeGroup(Node n) |
Constructor and Description |
---|
Group(org.jgrapht.DirectedGraph graph,
Node n) |
Constructor and Description |
---|
GraphGrouper(org.jgrapht.DirectedGraph<Node,IndexedEdge> graph,
Collection<Group> initialGroups) |
Group(org.jgrapht.DirectedGraph graph,
List<Node> nodes) |
Modifier and Type | Class and Description |
---|---|
class |
PartitionNode |
class |
ProcessorNode |
class |
SpoutNode |
Constructor and Description |
---|
SubtopologyBolt(org.jgrapht.DirectedGraph graph,
Set<Node> nodes,
Map<Node,String> batchGroups) |
SubtopologyBolt(org.jgrapht.DirectedGraph graph,
Set<Node> nodes,
Map<Node,String> batchGroups) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.