Skip to content

Instantly share code, notes, and snippets.

@ankurcha
Created June 12, 2016 00:07
Show Gist options
  • Save ankurcha/586b5170ec671bca9194adf57b235f34 to your computer and use it in GitHub Desktop.
Save ankurcha/586b5170ec671bca9194adf57b235f34 to your computer and use it in GitHub Desktop.
strict digraph "StepGraph" {
subgraph "cluster AnalyticsTransform" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform";
label="AnalyticsTransform";
subgraph "cluster AnalyticsTransform/ActivityEvents" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/ActivityEvents";
label="ActivityEvents";
"s3" [label="FlatMapEvent", tooltip="AnalyticsTransform/ActivityEvents/FlatMapEvent", style=filled, fillcolor=white];
"s4" [label="ParseAnalyticsEvent", tooltip="AnalyticsTransform/ActivityEvents/ParseAnalyticsEvent", style=filled, fillcolor=white];
}
"s149" [label="Sessionized.ClearStreamingFields", tooltip="AnalyticsTransform/Sessionized.ClearStreamingFields", style=filled, fillcolor=white];
subgraph "cluster AnalyticsTransform/Sessionized.PersistToBigTable" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.PersistToBigTable";
label="Sessionized.PersistToBigTable";
"s150" [label="PersistToBigTable.ConvertBigTablePutFn", tooltip="AnalyticsTransform/Sessionized.PersistToBigTable/PersistToBigTable.ConvertBigTablePutFn", style=filled, fillcolor=white];
"s151" [label="PersistToBigTable.WriteToBigTable/ParDo(CloudBigtableSingleTableBufferedWrite)", tooltip="AnalyticsTransform/Sessionized.PersistToBigTable/PersistToBigTable.WriteToBigTable/ParDo(CloudBigtableSingleTableBufferedWrite)", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows";
label="Sessionized.ResourceRows";
"s84" [label="ApplyStorageGranularityWindowing", tooltip="AnalyticsTransform/Sessionized.ResourceRows/ApplyStorageGranularityWindowing", style=filled, fillcolor=white];
"s148" [label="GetRows", tooltip="AnalyticsTransform/Sessionized.ResourceRows/GetRows", style=filled, fillcolor=white];
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]";
label="RollupBy[account]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow";
label="CombinePartialRow";
"s86" [label="AddNonce", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/AddNonce", style=filled, fillcolor=white];
"s92" [label="Flatten.FlattenPCollectionList", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/Flatten.FlattenPCollectionList", style=filled, fillcolor=white];
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine";
label="PostCombine";
"s94" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine/Combine.GroupedValues", style=filled, fillcolor=white];
"s93" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine/GroupByKey", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot";
label="PreCombineHot";
"s88" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot/Combine.GroupedValues", style=filled, fillcolor=white];
"s87" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot/GroupByKey", style=filled, fillcolor=white];
}
"s91" [label="PrepareCold", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/PrepareCold", style=filled, fillcolor=white];
"s89" [label="StripNonce", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/StripNonce", style=filled, fillcolor=white];
"s90" [label="Window.Remerge/Identity", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/CombinePartialRow/Window.Remerge/Identity", style=filled, fillcolor=white];
}
"s85" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/GenerateRollup", style=filled, fillcolor=white];
"s95" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[account]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]";
label="RollupBy[all]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]/CombinePartialRow";
label="CombinePartialRow";
"s98" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s97" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s96" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]/GenerateRollup", style=filled, fillcolor=white];
"s99" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[all]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]";
label="RollupBy[city]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]/CombinePartialRow";
label="CombinePartialRow";
"s102" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s101" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s100" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]/GenerateRollup", style=filled, fillcolor=white];
"s103" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[city]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]";
label="RollupBy[country]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]/CombinePartialRow";
label="CombinePartialRow";
"s106" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s105" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s104" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]/GenerateRollup", style=filled, fillcolor=white];
"s107" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[country]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]";
label="RollupBy[destination_domain]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]/CombinePartialRow";
label="CombinePartialRow";
"s110" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s109" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s108" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]/GenerateRollup", style=filled, fillcolor=white];
"s111" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_domain]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]";
label="RollupBy[destination_path]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]/CombinePartialRow";
label="CombinePartialRow";
"s114" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s113" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s112" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]/GenerateRollup", style=filled, fillcolor=white];
"s115" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[destination_path]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]";
label="RollupBy[device_os]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]/CombinePartialRow";
label="CombinePartialRow";
"s118" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s117" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s116" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]/GenerateRollup", style=filled, fillcolor=white];
"s119" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_os]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]";
label="RollupBy[device_type]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]/CombinePartialRow";
label="CombinePartialRow";
"s122" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s121" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s120" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]/GenerateRollup", style=filled, fillcolor=white];
"s123" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[device_type]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]";
label="RollupBy[player]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]/CombinePartialRow";
label="CombinePartialRow";
"s126" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s125" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s124" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]/GenerateRollup", style=filled, fillcolor=white];
"s127" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[player]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]";
label="RollupBy[referrer_domain]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow";
label="CombinePartialRow";
"s130" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s129" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s128" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]/GenerateRollup", style=filled, fillcolor=white];
"s131" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[referrer_domain]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]";
label="RollupBy[region]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]/CombinePartialRow";
label="CombinePartialRow";
"s134" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s133" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s132" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]/GenerateRollup", style=filled, fillcolor=white];
"s135" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[region]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]";
label="RollupBy[search_terms]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]/CombinePartialRow";
label="CombinePartialRow";
"s138" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s137" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s136" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]/GenerateRollup", style=filled, fillcolor=white];
"s139" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[search_terms]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]";
label="RollupBy[source_type]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]/CombinePartialRow";
label="CombinePartialRow";
"s142" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s141" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s140" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]/GenerateRollup", style=filled, fillcolor=white];
"s143" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[source_type]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]";
label="RollupBy[video]";
subgraph "cluster AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]/CombinePartialRow";
label="CombinePartialRow";
"s146" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s145" [label="GroupByKey", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s144" [label="GenerateRollup", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]/GenerateRollup", style=filled, fillcolor=white];
"s147" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Sessionized.ResourceRows/RollupBy[video]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
}
subgraph "cluster AnalyticsTransform/SessionizedAdditions" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/SessionizedAdditions";
label="SessionizedAdditions";
"s83" [label="AggregateEventsToRow", tooltip="AnalyticsTransform/SessionizedAdditions/AggregateEventsToRow", style=filled, fillcolor=white];
"s74" [label="FilterOutNonV2Events", tooltip="AnalyticsTransform/SessionizedAdditions/FilterOutNonV2Events", style=filled, fillcolor=white];
subgraph "cluster AnalyticsTransform/SessionizedAdditions/SessionizeEvents" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/SessionizedAdditions/SessionizeEvents";
label="SessionizeEvents";
"s81" [label="ApplySessionWindowing", tooltip="AnalyticsTransform/SessionizedAdditions/SessionizeEvents/ApplySessionWindowing", style=filled, fillcolor=white];
"s79" [label="GroupBySessionId", tooltip="AnalyticsTransform/SessionizedAdditions/SessionizeEvents/GroupBySessionId", style=filled, fillcolor=white];
"s82" [label="GroupByVideoSessionId", tooltip="AnalyticsTransform/SessionizedAdditions/SessionizeEvents/GroupByVideoSessionId", style=filled, fillcolor=white];
"s77" [label="KeyByPlayerSessionId", tooltip="AnalyticsTransform/SessionizedAdditions/SessionizeEvents/KeyByPlayerSessionId", style=filled, fillcolor=white];
"s80" [label="KeyByVideoSessionId", tooltip="AnalyticsTransform/SessionizedAdditions/SessionizeEvents/KeyByVideoSessionId", style=filled, fillcolor=white];
"s78" [label="SlidingWindows", tooltip="AnalyticsTransform/SessionizedAdditions/SessionizeEvents/SlidingWindows", style=filled, fillcolor=white];
}
"s76" [label="ToVideoSessionEvent", tooltip="AnalyticsTransform/SessionizedAdditions/ToVideoSessionEvent", style=filled, fillcolor=white];
"s75" [label="ValidateSessionId", tooltip="AnalyticsTransform/SessionizedAdditions/ValidateSessionId", style=filled, fillcolor=white];
}
"s71" [label="Streaming.ClearSessionizedFields", tooltip="AnalyticsTransform/Streaming.ClearSessionizedFields", style=filled, fillcolor=white];
subgraph "cluster AnalyticsTransform/Streaming.PersistToBigTable" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.PersistToBigTable";
label="Streaming.PersistToBigTable";
"s72" [label="PersistToBigTable.ConvertBigTablePutFn", tooltip="AnalyticsTransform/Streaming.PersistToBigTable/PersistToBigTable.ConvertBigTablePutFn", style=filled, fillcolor=white];
"s73" [label="PersistToBigTable.WriteToBigTable/ParDo(CloudBigtableSingleTableBufferedWrite)", tooltip="AnalyticsTransform/Streaming.PersistToBigTable/PersistToBigTable.WriteToBigTable/ParDo(CloudBigtableSingleTableBufferedWrite)", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows";
label="Streaming.ResourceRows";
"s6" [label="ApplyStorageGranularityWindowing", tooltip="AnalyticsTransform/Streaming.ResourceRows/ApplyStorageGranularityWindowing", style=filled, fillcolor=white];
"s70" [label="GetRows", tooltip="AnalyticsTransform/Streaming.ResourceRows/GetRows", style=filled, fillcolor=white];
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]";
label="RollupBy[account]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow";
label="CombinePartialRow";
"s8" [label="AddNonce", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/AddNonce", style=filled, fillcolor=white];
"s14" [label="Flatten.FlattenPCollectionList", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/Flatten.FlattenPCollectionList", style=filled, fillcolor=white];
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine";
label="PostCombine";
"s16" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine/Combine.GroupedValues", style=filled, fillcolor=white];
"s15" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PostCombine/GroupByKey", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot";
label="PreCombineHot";
"s10" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot/Combine.GroupedValues", style=filled, fillcolor=white];
"s9" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PreCombineHot/GroupByKey", style=filled, fillcolor=white];
}
"s13" [label="PrepareCold", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/PrepareCold", style=filled, fillcolor=white];
"s11" [label="StripNonce", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/StripNonce", style=filled, fillcolor=white];
"s12" [label="Window.Remerge/Identity", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/CombinePartialRow/Window.Remerge/Identity", style=filled, fillcolor=white];
}
"s7" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/GenerateRollup", style=filled, fillcolor=white];
"s17" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[account]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]";
label="RollupBy[all]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]/CombinePartialRow";
label="CombinePartialRow";
"s20" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s19" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s18" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]/GenerateRollup", style=filled, fillcolor=white];
"s21" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[all]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]";
label="RollupBy[city]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]/CombinePartialRow";
label="CombinePartialRow";
"s24" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s23" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s22" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]/GenerateRollup", style=filled, fillcolor=white];
"s25" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[city]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]";
label="RollupBy[country]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]/CombinePartialRow";
label="CombinePartialRow";
"s28" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s27" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s26" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]/GenerateRollup", style=filled, fillcolor=white];
"s29" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[country]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]";
label="RollupBy[destination_domain]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]/CombinePartialRow";
label="CombinePartialRow";
"s32" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s31" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s30" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]/GenerateRollup", style=filled, fillcolor=white];
"s33" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_domain]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]";
label="RollupBy[destination_path]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]/CombinePartialRow";
label="CombinePartialRow";
"s36" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s35" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s34" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]/GenerateRollup", style=filled, fillcolor=white];
"s37" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[destination_path]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]";
label="RollupBy[device_os]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]/CombinePartialRow";
label="CombinePartialRow";
"s40" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s39" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s38" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]/GenerateRollup", style=filled, fillcolor=white];
"s41" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_os]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]";
label="RollupBy[device_type]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]/CombinePartialRow";
label="CombinePartialRow";
"s44" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s43" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s42" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]/GenerateRollup", style=filled, fillcolor=white];
"s45" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[device_type]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]";
label="RollupBy[player]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]/CombinePartialRow";
label="CombinePartialRow";
"s48" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s47" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s46" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]/GenerateRollup", style=filled, fillcolor=white];
"s49" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[player]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]";
label="RollupBy[referrer_domain]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow";
label="CombinePartialRow";
"s52" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s51" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s50" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]/GenerateRollup", style=filled, fillcolor=white];
"s53" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[referrer_domain]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]";
label="RollupBy[region]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]/CombinePartialRow";
label="CombinePartialRow";
"s56" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s55" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s54" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]/GenerateRollup", style=filled, fillcolor=white];
"s57" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[region]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]";
label="RollupBy[search_terms]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]/CombinePartialRow";
label="CombinePartialRow";
"s60" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s59" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s58" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]/GenerateRollup", style=filled, fillcolor=white];
"s61" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[search_terms]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]";
label="RollupBy[source_type]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]/CombinePartialRow";
label="CombinePartialRow";
"s64" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s63" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s62" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]/GenerateRollup", style=filled, fillcolor=white];
"s65" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[source_type]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]";
label="RollupBy[video]";
subgraph "cluster AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]/CombinePartialRow" {
style=filled;
bgcolor=white;
labeljust=left;
tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]/CombinePartialRow";
label="CombinePartialRow";
"s68" [label="Combine.GroupedValues", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]/CombinePartialRow/Combine.GroupedValues", style=filled, fillcolor=white];
"s67" [label="GroupByKey", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]/CombinePartialRow/GroupByKey", style=filled, fillcolor=white];
}
"s66" [label="GenerateRollup", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]/GenerateRollup", style=filled, fillcolor=white];
"s69" [label="GetCombinedRow/Values", tooltip="AnalyticsTransform/Streaming.ResourceRows/RollupBy[video]/GetCombinedRow/Values", style=filled, fillcolor=white];
}
}
"s5" [label="StreamingAdditions/ActivityEventsToRow", tooltip="AnalyticsTransform/StreamingAdditions/ActivityEventsToRow", style=filled, fillcolor=white];
}
"s1" [label="PubSubReader", tooltip="PubSubReader", style=filled, fillcolor=white];
"s2" [label="SnappyDecompress/ParDo(MultiThreadedIntraBundleProcessing)", tooltip="SnappyDecompress/ParDo(MultiThreadedIntraBundleProcessing)", style=filled, fillcolor=white];
"s1" -> "s2" [taillabel="output", style=solid];
"s2" -> "s3" [taillabel="output", style=solid];
"s3" -> "s4" [taillabel="output", style=solid];
"s4" -> "s5" [taillabel="output", style=solid];
"s5" -> "s6" [taillabel="output", style=solid];
"s6" -> "s7" [taillabel="output", style=solid];
"s7" -> "s8" [taillabel="output", style=solid];
"s8" -> "s9" [taillabel="com.google.cloud.dataflow.sdk.transforms.Combine$PerKeyWithHotKeyFanout.applyHelper:2022#bb20b45fd4d95138", style=solid];
"s9" -> "s10" [taillabel="output", style=solid];
"s10" -> "s11" [taillabel="output", style=solid];
"s11" -> "s12" [taillabel="output", style=solid];
"s8" -> "s13" [taillabel="com.google.cloud.dataflow.sdk.transforms.Combine$PerKeyWithHotKeyFanout.applyHelper:2023#3d93cb799b3970be", style=solid];
"s12" -> "s14" [taillabel="output", style=solid];
"s13" -> "s14" [taillabel="output", style=solid];
"s14" -> "s15" [taillabel="output", style=solid];
"s15" -> "s16" [taillabel="output", style=solid];
"s16" -> "s17" [taillabel="output", style=solid];
"s6" -> "s18" [taillabel="output", style=solid];
"s18" -> "s19" [taillabel="output", style=solid];
"s19" -> "s20" [taillabel="output", style=solid];
"s20" -> "s21" [taillabel="output", style=solid];
"s6" -> "s22" [taillabel="output", style=solid];
"s22" -> "s23" [taillabel="output", style=solid];
"s23" -> "s24" [taillabel="output", style=solid];
"s24" -> "s25" [taillabel="output", style=solid];
"s6" -> "s26" [taillabel="output", style=solid];
"s26" -> "s27" [taillabel="output", style=solid];
"s27" -> "s28" [taillabel="output", style=solid];
"s28" -> "s29" [taillabel="output", style=solid];
"s6" -> "s30" [taillabel="output", style=solid];
"s30" -> "s31" [taillabel="output", style=solid];
"s31" -> "s32" [taillabel="output", style=solid];
"s32" -> "s33" [taillabel="output", style=solid];
"s6" -> "s34" [taillabel="output", style=solid];
"s34" -> "s35" [taillabel="output", style=solid];
"s35" -> "s36" [taillabel="output", style=solid];
"s36" -> "s37" [taillabel="output", style=solid];
"s6" -> "s38" [taillabel="output", style=solid];
"s38" -> "s39" [taillabel="output", style=solid];
"s39" -> "s40" [taillabel="output", style=solid];
"s40" -> "s41" [taillabel="output", style=solid];
"s6" -> "s42" [taillabel="output", style=solid];
"s42" -> "s43" [taillabel="output", style=solid];
"s43" -> "s44" [taillabel="output", style=solid];
"s44" -> "s45" [taillabel="output", style=solid];
"s6" -> "s46" [taillabel="output", style=solid];
"s46" -> "s47" [taillabel="output", style=solid];
"s47" -> "s48" [taillabel="output", style=solid];
"s48" -> "s49" [taillabel="output", style=solid];
"s6" -> "s50" [taillabel="output", style=solid];
"s50" -> "s51" [taillabel="output", style=solid];
"s51" -> "s52" [taillabel="output", style=solid];
"s52" -> "s53" [taillabel="output", style=solid];
"s6" -> "s54" [taillabel="output", style=solid];
"s54" -> "s55" [taillabel="output", style=solid];
"s55" -> "s56" [taillabel="output", style=solid];
"s56" -> "s57" [taillabel="output", style=solid];
"s6" -> "s58" [taillabel="output", style=solid];
"s58" -> "s59" [taillabel="output", style=solid];
"s59" -> "s60" [taillabel="output", style=solid];
"s60" -> "s61" [taillabel="output", style=solid];
"s6" -> "s62" [taillabel="output", style=solid];
"s62" -> "s63" [taillabel="output", style=solid];
"s63" -> "s64" [taillabel="output", style=solid];
"s64" -> "s65" [taillabel="output", style=solid];
"s6" -> "s66" [taillabel="output", style=solid];
"s66" -> "s67" [taillabel="output", style=solid];
"s67" -> "s68" [taillabel="output", style=solid];
"s68" -> "s69" [taillabel="output", style=solid];
"s17" -> "s70" [taillabel="output", style=solid];
"s21" -> "s70" [taillabel="output", style=solid];
"s25" -> "s70" [taillabel="output", style=solid];
"s29" -> "s70" [taillabel="output", style=solid];
"s33" -> "s70" [taillabel="output", style=solid];
"s37" -> "s70" [taillabel="output", style=solid];
"s41" -> "s70" [taillabel="output", style=solid];
"s45" -> "s70" [taillabel="output", style=solid];
"s49" -> "s70" [taillabel="output", style=solid];
"s53" -> "s70" [taillabel="output", style=solid];
"s57" -> "s70" [taillabel="output", style=solid];
"s61" -> "s70" [taillabel="output", style=solid];
"s65" -> "s70" [taillabel="output", style=solid];
"s69" -> "s70" [taillabel="output", style=solid];
"s70" -> "s71" [taillabel="output", style=solid];
"s71" -> "s72" [taillabel="output", style=solid];
"s72" -> "s73" [taillabel="output", style=solid];
"s4" -> "s74" [taillabel="output", style=solid];
"s74" -> "s75" [taillabel="output", style=solid];
"s75" -> "s76" [taillabel="output", style=solid];
"s76" -> "s77" [taillabel="output", style=solid];
"s77" -> "s78" [taillabel="output", style=solid];
"s78" -> "s79" [taillabel="output", style=solid];
"s79" -> "s80" [taillabel="output", style=solid];
"s80" -> "s81" [taillabel="output", style=solid];
"s81" -> "s82" [taillabel="output", style=solid];
"s82" -> "s83" [taillabel="output", style=solid];
"s83" -> "s84" [taillabel="output", style=solid];
"s84" -> "s85" [taillabel="output", style=solid];
"s85" -> "s86" [taillabel="output", style=solid];
"s86" -> "s87" [taillabel="com.google.cloud.dataflow.sdk.transforms.Combine$PerKeyWithHotKeyFanout.applyHelper:2022#a32dc9f64f1df03a", style=solid];
"s87" -> "s88" [taillabel="output", style=solid];
"s88" -> "s89" [taillabel="output", style=solid];
"s89" -> "s90" [taillabel="output", style=solid];
"s86" -> "s91" [taillabel="com.google.cloud.dataflow.sdk.transforms.Combine$PerKeyWithHotKeyFanout.applyHelper:2023#8ce970b71df42503", style=solid];
"s90" -> "s92" [taillabel="output", style=solid];
"s91" -> "s92" [taillabel="output", style=solid];
"s92" -> "s93" [taillabel="output", style=solid];
"s93" -> "s94" [taillabel="output", style=solid];
"s94" -> "s95" [taillabel="output", style=solid];
"s84" -> "s96" [taillabel="output", style=solid];
"s96" -> "s97" [taillabel="output", style=solid];
"s97" -> "s98" [taillabel="output", style=solid];
"s98" -> "s99" [taillabel="output", style=solid];
"s84" -> "s100" [taillabel="output", style=solid];
"s100" -> "s101" [taillabel="output", style=solid];
"s101" -> "s102" [taillabel="output", style=solid];
"s102" -> "s103" [taillabel="output", style=solid];
"s84" -> "s104" [taillabel="output", style=solid];
"s104" -> "s105" [taillabel="output", style=solid];
"s105" -> "s106" [taillabel="output", style=solid];
"s106" -> "s107" [taillabel="output", style=solid];
"s84" -> "s108" [taillabel="output", style=solid];
"s108" -> "s109" [taillabel="output", style=solid];
"s109" -> "s110" [taillabel="output", style=solid];
"s110" -> "s111" [taillabel="output", style=solid];
"s84" -> "s112" [taillabel="output", style=solid];
"s112" -> "s113" [taillabel="output", style=solid];
"s113" -> "s114" [taillabel="output", style=solid];
"s114" -> "s115" [taillabel="output", style=solid];
"s84" -> "s116" [taillabel="output", style=solid];
"s116" -> "s117" [taillabel="output", style=solid];
"s117" -> "s118" [taillabel="output", style=solid];
"s118" -> "s119" [taillabel="output", style=solid];
"s84" -> "s120" [taillabel="output", style=solid];
"s120" -> "s121" [taillabel="output", style=solid];
"s121" -> "s122" [taillabel="output", style=solid];
"s122" -> "s123" [taillabel="output", style=solid];
"s84" -> "s124" [taillabel="output", style=solid];
"s124" -> "s125" [taillabel="output", style=solid];
"s125" -> "s126" [taillabel="output", style=solid];
"s126" -> "s127" [taillabel="output", style=solid];
"s84" -> "s128" [taillabel="output", style=solid];
"s128" -> "s129" [taillabel="output", style=solid];
"s129" -> "s130" [taillabel="output", style=solid];
"s130" -> "s131" [taillabel="output", style=solid];
"s84" -> "s132" [taillabel="output", style=solid];
"s132" -> "s133" [taillabel="output", style=solid];
"s133" -> "s134" [taillabel="output", style=solid];
"s134" -> "s135" [taillabel="output", style=solid];
"s84" -> "s136" [taillabel="output", style=solid];
"s136" -> "s137" [taillabel="output", style=solid];
"s137" -> "s138" [taillabel="output", style=solid];
"s138" -> "s139" [taillabel="output", style=solid];
"s84" -> "s140" [taillabel="output", style=solid];
"s140" -> "s141" [taillabel="output", style=solid];
"s141" -> "s142" [taillabel="output", style=solid];
"s142" -> "s143" [taillabel="output", style=solid];
"s84" -> "s144" [taillabel="output", style=solid];
"s144" -> "s145" [taillabel="output", style=solid];
"s145" -> "s146" [taillabel="output", style=solid];
"s146" -> "s147" [taillabel="output", style=solid];
"s95" -> "s148" [taillabel="output", style=solid];
"s99" -> "s148" [taillabel="output", style=solid];
"s103" -> "s148" [taillabel="output", style=solid];
"s107" -> "s148" [taillabel="output", style=solid];
"s111" -> "s148" [taillabel="output", style=solid];
"s115" -> "s148" [taillabel="output", style=solid];
"s119" -> "s148" [taillabel="output", style=solid];
"s123" -> "s148" [taillabel="output", style=solid];
"s127" -> "s148" [taillabel="output", style=solid];
"s131" -> "s148" [taillabel="output", style=solid];
"s135" -> "s148" [taillabel="output", style=solid];
"s139" -> "s148" [taillabel="output", style=solid];
"s143" -> "s148" [taillabel="output", style=solid];
"s147" -> "s148" [taillabel="output", style=solid];
"s148" -> "s149" [taillabel="output", style=solid];
"s149" -> "s150" [taillabel="output", style=solid];
"s150" -> "s151" [taillabel="output", style=solid];
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment