com.pervasive.datarush.operators

Class OperatorProxies.ExecutableOperatorProxy

java.lang.Object

com.pervasive.datarush.operators.OperatorProxies.OperatorProxy

com.pervasive.datarush.operators.OperatorProxies.StreamingOperatorProxy

com.pervasive.datarush.operators.OperatorProxies.ExecutableOperatorProxy

Enclosing class:

OperatorProxies

public static final class OperatorProxies.ExecutableOperatorProxy
extends OperatorProxies.StreamingOperatorProxy

Public only as a matter of implementation; not intended for external use

Method Summary

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

Methods inherited from class com.pervasive.datarush.operators.OperatorProxies.StreamingOperatorProxy

computeMetadata

Methods inherited from class com.pervasive.datarush.operators.OperatorProxies.OperatorProxy

isParallelismDisabled, notifyError, setParallelismDisabled

Methods inherited from class java.lang.Object

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

Method Detail

getPortSettings

public PortSetting[] getPortSettings(LogicalPort outputPort)

Public only as a matter of implementation; not intended for external use

Parameters:

outputPort - the output port

Returns:

the port settings

getNumInputCopies

public int getNumInputCopies(LogicalPort inputPort)

Public only as a matter of implementation; not intended for external use

Parameters:

inputPort - the output port

Returns:

the number of copies

handleInactiveOutput

public boolean handleInactiveOutput(LogicalPort output)

Public only as a matter of implementation; not intended for external use

Parameters:

output - the output port

Returns:

if the operator should terminate

execute

public void execute(ExecutionContext ctx)

Public only as a matter of implementation; not intended for external use

Parameters:

ctx - the execution context

cloneForExecution

public OperatorProxies.ExecutableOperatorProxy cloneForExecution()

Public only as a matter of implementation; not intended for external use

Returns:

a clone of this operator

getTarget

public ExecutableOperator getTarget()

Description copied from class: OperatorProxies.OperatorProxy

Public only as a matter of implementation; not intended for external use

Overrides:

getTarget in class OperatorProxies.StreamingOperatorProxy

Returns:

the target operator