complex Y Normal N 1000 100 - 2020/07/27 14:56:38.114 - 2020/07/27 14:56:38.114 H4sIAAAAAAAAAAMAAAAAAAAAAAA= N Customer data Merge join Y State data uppercase state Y uppercase state Merge join Y Customer data countPerState Y countPerState Lookup count per state Y Merge join Lookup count per state Y Lookup count per state name<n Y name<n Label: A-M Y name<n Label: N-Z Y Label: A-M Switch / case Y Label: N-Z Switch / case Y Switch / case CA Y Switch / case FL Y Switch / case NY Y Switch / case Default Y CA Collect Y FL Collect Y NY Collect Y Default Collect Y Collect complex Y CA Constant Y 1 none Comment String Some comment about California -1 -1 N 864 32 Collect Dummy Y 1 none 1008 128 Customer data BeamInput N 1 none ${DATA_INPUT} Customers 144 128 Default Constant Y 1 none Comment String no comment. -1 -1 N 864 224 FL Constant Y 1 none Comment String Some remark on Floridians -1 -1 N 864 96 Label: A-M Constant Y 1 none label String A-M -1 -1 N 608 32 Label: N-Z Constant Y 1 none label String N-Z -1 -1 N 608 224 Lookup count per state StreamLookup Y 1 none countPerState N N N Y stateCode stateCode countPerState nrPerState Integer 400 128 Merge join MergeJoin Y 1 none LEFT OUTER Customer data uppercase state state state 288 128 NY Constant Y 1 none Comment String New York rocks! -1 -1 N 864 160 State data BeamInput Y 1 none ${STATE_INPUT} State population data 144 224 Switch / case SwitchCase Y 1 none stateCode N String Default CA CA FL FL NY NY 704 128 complex BeamOutput Y 1 none ${DATA_OUTPUT} complex .csv N 1152 128 countPerState MemoryGroupBy Y 1 none N stateCode countPerState id COUNT_ALL 288 16 name<n FilterRows Y 1 none Label: A-M Label: N-Z N Last name < constant String n -1 -1 N 512 128 uppercase state StringOperations Y 1 none state none upper none no none none none 288 224