public static final class OperatorProxies.ExecutableOperatorProxy extends OperatorProxies.StreamingOperatorProxy
Modifier and Type | Method and Description |
---|---|
OperatorProxies.ExecutableOperatorProxy |
cloneForExecution()
Public only as a matter of implementation; not intended for external use
|
void |
execute(ExecutionContext ctx)
Public only as a matter of implementation; not intended for external use
|
int |
getNumInputCopies(LogicalPort inputPort)
Public only as a matter of implementation; not intended for external use
|
PortSetting[] |
getPortSettings(LogicalPort outputPort)
Public only as a matter of implementation; not intended for external use
|
ExecutableOperator |
getTarget()
Public only as a matter of implementation; not intended for external use
|
boolean |
handleInactiveOutput(LogicalPort output)
Public only as a matter of implementation; not intended for external use
|
computeMetadata
isParallelismDisabled, notifyError, setParallelismDisabled
public PortSetting[] getPortSettings(LogicalPort outputPort)
outputPort
- the output portpublic int getNumInputCopies(LogicalPort inputPort)
inputPort
- the output portpublic boolean handleInactiveOutput(LogicalPort output)
output
- the output portpublic void execute(ExecutionContext ctx)
ctx
- the execution contextpublic OperatorProxies.ExecutableOperatorProxy cloneForExecution()
public ExecutableOperator getTarget()
OperatorProxies.OperatorProxy
getTarget
in class OperatorProxies.StreamingOperatorProxy
Copyright © 2024 Actian Corporation. All rights reserved.