Skip to content
This repository has been archived by the owner on Jan 20, 2022. It is now read-only.

Feature/add storm dot graph #236

Merged
merged 17 commits into from
Sep 22, 2013
Merged

Feature/add storm dot graph #236

Changes from 1 commit
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
058a2ad
Add's separate generation of a planned storm graph.
ianoc Sep 19, 2013
390eecf
Add the SummerStormBolt, IntermediateFlatMapBolt, and FinalFlatMapBolt
ianoc Sep 19, 2013
095e857
LUT -> LookupTable
ianoc Sep 19, 2013
d548c17
Handle N-Way Merge
ianoc Sep 20, 2013
3f3baae
Move the new generation into a StormTopologyGenerator, add some initi…
ianoc Sep 20, 2013
c6d9435
Add tests for planner
ianoc Sep 20, 2013
1087e7e
Add more tests, ensure we have 3 layers in all graphs
ianoc Sep 20, 2013
4a79258
Added flatMap generators
ianoc Sep 20, 2013
3fcb2cd
Remove whitespace changes to the StormPlatform.scala file
ianoc Sep 20, 2013
fc083b1
Fixes a topo in Topology
ianoc Sep 20, 2013
b4e989b
Remove the remove function, remove brackets from reverse
ianoc Sep 20, 2013
b826cc2
Make resolve mergableWithSource, a boolean returning function.
ianoc Sep 20, 2013
3e9501f
Fixes some bugs in handling of MergedProducers in the topology when t…
ianoc Sep 21, 2013
64b481c
Don't hide the identity keyed producer in the viz graph
ianoc Sep 21, 2013
4bef8e9
Updates to reflect comments from github
ianoc Sep 21, 2013
59a4905
Enable WrittenProducer's in the generated tree, stop dumping all grap…
ianoc Sep 22, 2013
1ce815c
Fix bad comment
ianoc Sep 22, 2013
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Don't hide the identity keyed producer in the viz graph
  • Loading branch information
@ianoc
ianoc committed Sep 21, 2013
commit 64b481c16878342c143dd69ec2d1d7f75592c61a
3 changes: 0 additions & 3 deletions summingbird-core/src/main/scala/com/twitter/summingbird/viz/Viz.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,6 @@ case class VizGraph[P <: Platform[P]](tail: Producer[P, _]) {
children.headOption match {
case Some(child: NamedProducer[_, _]) =>
recurseGetNode(child, Some(child.id))
case Some(child: IdentityKeyedProducer[_, _, _]) =>
recurseGetNode(child, Some(name))
case _ =>
(name, n, children)
}
Expand All @@ -60,7 +58,6 @@ case class VizGraph[P <: Platform[P]](tail: Producer[P, _]) {
val (graphStr, _) = dependantState.nodes.foldLeft(("", emptyNameLookupTable)) { case ((runningStr, nameLookupTable), nextNode) =>
nextNode match {
case NamedProducer(parent, name) => (runningStr, nameLookupTable)
case IdentityKeyedProducer(_) => (runningStr, nameLookupTable)
case _ =>
// Compute the lines and new names for the nextNode
val (rawNodeName, evalNode, children) = recurseGetNode(nextNode)
Expand Down