@Test public void testEmptyFlow() throws Exception { ProcessGroupStatus rootPG = createEmptyProcessGroupStatus(); final NiFiFlowAnalyzer analyzer = new NiFiFlowAnalyzer(); final NiFiFlow nifiFlow = new NiFiFlow(rootPG.getId()); nifiFlow.setClusterName("cluster1"); analyzer.analyzeProcessGroup(nifiFlow, rootPG); assertEquals("1234-5678-0000-0000@cluster1", nifiFlow.getQualifiedName()); }
public void analyzeProcessGroup(NiFiFlow nifiFlow, ProcessGroupStatus rootProcessGroup) { analyzeProcessGroup(rootProcessGroup, nifiFlow); analyzeRootGroupPorts(nifiFlow, rootProcessGroup); }
NiFiFlowAnalyzer { public void analyzeProcessGroup(NiFiFlow nifiFlow, ProcessGroupStatus rootProcessGroup) { analyzeProcessGroup(rootProcessGroup, nifiFlow); analyzeRootGroupPorts(nifiFlow, rootProcessGroup); } }
NiFiFlowAnalyzer { public void analyzeProcessGroup(NiFiFlow nifiFlow, ProcessGroupStatus rootProcessGroup) { analyzeProcessGroup(rootProcessGroup, nifiFlow); analyzeRootGroupPorts(nifiFlow, rootProcessGroup); }  }
NiFiFlowAnalyzer { public void analyzeProcessGroup(NiFiFlow nifiFlow, ProcessGroupStatus rootProcessGroup) { analyzeProcessGroup(rootProcessGroup, nifiFlow); analyzeRootGroupPorts(nifiFlow, rootProcessGroup); }  void analyzeProcessGroup(NiFiFlow nifiFlow, ProcessGroupStatus rootProcessGroup); void analyzePaths(NiFiFlow nifiFlow); }
NiFiFlowAnalyzer { public void analyzeProcessGroup(NiFiFlow nifiFlow, ProcessGroupStatus rootProcessGroup) { analyzeProcessGroup(rootProcessGroup, nifiFlow); analyzeRootGroupPorts(nifiFlow, rootProcessGroup); }  void analyzeProcessGroup(NiFiFlow nifiFlow, ProcessGroupStatus rootProcessGroup); void analyzePaths(NiFiFlow nifiFlow);  }