com.espertech.esper.dataflow.util
Class LogicalChannelUtil

java.lang.Object
  com.espertech.esper.dataflow.util.LogicalChannelUtil

public class LogicalChannelUtil
extends java.lang.Object

Constructor Summary

LogicalChannelUtil()

Method Summary

static java.util.List<LogicalChannelBinding>	getBindingsConsuming(int producerOpNum, java.util.List<LogicalChannelBinding> bindings)
static java.util.List<LogicalChannelProducingPortCompiled>	getOutputPortByStreamName(java.util.Set<java.lang.Integer> incomingOpNums, java.lang.String[] inputStreamNames, java.util.Map<java.lang.Integer,java.util.List<LogicalChannelProducingPortCompiled>> compiledOutputPorts)
static java.lang.String	printChannels(java.util.List<LogicalChannel> channels)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LogicalChannelUtil

public LogicalChannelUtil()

Method Detail

getBindingsConsuming

public static java.util.List<LogicalChannelBinding> getBindingsConsuming(int producerOpNum,
                                                                         java.util.List<LogicalChannelBinding> bindings)

printChannels

public static java.lang.String printChannels(java.util.List<LogicalChannel> channels)

getOutputPortByStreamName

public static java.util.List<LogicalChannelProducingPortCompiled> getOutputPortByStreamName(java.util.Set<java.lang.Integer> incomingOpNums,
                                                                                            java.lang.String[] inputStreamNames,
                                                                                            java.util.Map<java.lang.Integer,java.util.List<LogicalChannelProducingPortCompiled>> compiledOutputPorts)