tcpDstFlows.addFilter(dstWellKnownPorts);
statsRules.add(new PortDistributionRule(tcpDstFlows, new FileOutputStream("flowsTcpDstPorts.csv", true), true));
/* TCP source ports */
final AndFilter tcpSrcFlows = new AndFilter();
tcpSrcFlows.addFilter(tcpFlows);
tcpSrcFlows.addFilter(srcWellKnownPorts);
statsRules.add(new PortDistributionRule(tcpSrcFlows, new FileOutputStream("flowsTcpSrcPorts.csv", true), false));
/* UDP destination ports */
final AndFilter udpDstFlows = new AndFilter();