Class LogicalChannel
java.lang.Object
com.espertech.esper.common.internal.epl.dataflow.realize.LogicalChannel
Models a pipe between two operators.
-
Field Summary
-
Constructor Summary
ConstructorDescriptionLogicalChannel
(int channelId, String consumingOpName, int consumingOpNum, int consumingOpStreamNum, String consumingOpStreamName, String consumingOptStreamAliasName, String consumingOpPrettyPrint, LogicalChannelProducingPortCompiled outputPort) -
Method Summary
Modifier and TypeMethodDescriptionint
int
int
make
(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope) void
setChannelId
(int channelId) void
setConsumingOpName
(String consumingOpName) void
setConsumingOpNum
(int consumingOpNum) void
setConsumingOpPrettyPrint
(String consumingOpPrettyPrint) void
setConsumingOpStreamName
(String consumingOpStreamName) void
setConsumingOpStreamNum
(int consumingOpStreamNum) void
setConsumingOptStreamAliasName
(String consumingOptStreamAliasName) void
setOutputPort
(LogicalChannelProducingPortCompiled outputPort) toString()
-
Field Details
-
EPTYPE
-
-
Constructor Details
-
LogicalChannel
public LogicalChannel() -
LogicalChannel
public LogicalChannel(int channelId, String consumingOpName, int consumingOpNum, int consumingOpStreamNum, String consumingOpStreamName, String consumingOptStreamAliasName, String consumingOpPrettyPrint, LogicalChannelProducingPortCompiled outputPort)
-
-
Method Details
-
make
public CodegenExpression make(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope) -
getChannelId
public int getChannelId() -
getConsumingOpName
-
getConsumingOpStreamName
-
getConsumingOptStreamAliasName
-
getConsumingOpStreamNum
public int getConsumingOpStreamNum() -
getConsumingOpNum
public int getConsumingOpNum() -
getOutputPort
-
getConsumingOpPrettyPrint
-
setChannelId
public void setChannelId(int channelId) -
setConsumingOpName
-
setConsumingOpNum
public void setConsumingOpNum(int consumingOpNum) -
setConsumingOpStreamNum
public void setConsumingOpStreamNum(int consumingOpStreamNum) -
setConsumingOpStreamName
-
setConsumingOptStreamAliasName
-
setConsumingOpPrettyPrint
-
setOutputPort
-
toString
-