| 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.apache.storm.shade.org.jgrapht.DirectedGraph graph,
Node n) |
| Constructor and Description |
|---|
GraphGrouper(org.apache.storm.shade.org.jgrapht.DirectedGraph<Node,IndexedEdge> graph,
Collection<Group> initialGroups) |
Group(org.apache.storm.shade.org.jgrapht.DirectedGraph graph,
List<Node> nodes) |
| Modifier and Type | Class and Description |
|---|---|
class |
PartitionNode |
class |
ProcessorNode |
class |
SpoutNode |
| Constructor and Description |
|---|
SubtopologyBolt(org.apache.storm.shade.org.jgrapht.graph.DefaultDirectedGraph<Node,IndexedEdge> graph,
Set<Node> nodes,
Map<Node,String> batchGroups) |
SubtopologyBolt(org.apache.storm.shade.org.jgrapht.graph.DefaultDirectedGraph<Node,IndexedEdge> graph,
Set<Node> nodes,
Map<Node,String> batchGroups) |
SubtopologyBolt(org.apache.storm.shade.org.jgrapht.graph.DefaultDirectedGraph<Node,IndexedEdge> graph,
Set<Node> nodes,
Map<Node,String> batchGroups) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.