public abstract class AbstractLogicalOperator extends Object implements LogicalOperator
LogicalOperator
Modifier and Type | Method and Description |
---|---|
void |
disableParallelism()
Can be called to forcible disable parallelism for the given
operator (and children if this is a
CompositeOperator ). |
Namespace<LogicalPort> |
getInputPorts()
Returns the list of input ports.
|
Namespace<LogicalPort> |
getOutputPorts()
Returns the list of output ports.
|
protected <T extends LogicalPort> |
newInput(String name,
LogicalPortFactory<T> factory)
Creates a new input port.
|
protected <T extends LogicalPort> |
newInput(String name,
LogicalPortFactory<T> factory,
boolean optional)
Creates a new input port.
|
protected <T extends LogicalPort> |
newOutput(String name,
LogicalPortFactory<T> factory)
Creates a new output port.
|
protected RecordPort |
newRecordInput(String name)
Creates a new record input port.
|
protected RecordPort |
newRecordInput(String name,
boolean optional)
Creates a new record input port.
|
protected RecordPort |
newRecordOutput(String name)
Creates a new record output port.
|
protected void |
notifyError(Throwable e)
Called to notify the operator that the graph terminated abnormally
either before the operator had a chance to run or while the operator
is running.
|
public final Namespace<LogicalPort> getInputPorts()
LogicalOperator
getInput()
, etc
to obtain a handle to input ports.getInputPorts
in interface LogicalOperator
public final Namespace<LogicalPort> getOutputPorts()
LogicalOperator
getOutput()
, etc
to obtain a handle to input ports.getOutputPorts
in interface LogicalOperator
public final void disableParallelism()
LogicalOperator
CompositeOperator
).
This method should be used sparingly since it will degrade performance significantly; but is needed in certain cases.
For example:
RunScript
operator that contains a non-parallelizable scriptDeriveFields
operator that contains a non-parallelizable functiondisableParallelism
in interface LogicalOperator
protected void notifyError(Throwable e)
CompositeOperator
, this method will
be invoked if any of the componentse
- the error that occuredprotected final RecordPort newRecordInput(String name)
name
- the name of the port, must be unique within the operator.LogicalOperator
protected final RecordPort newRecordInput(String name, boolean optional)
name
- the name of the port, must be unique within the operator.optional
- whether the port is optional.LogicalOperator
protected final <T extends LogicalPort> T newInput(String name, LogicalPortFactory<T> factory)
T
- the type of the portname
- the name of the port, must be unique within the operator.factory
- the factory, determines the type of the portLogicalOperator
protected final <T extends LogicalPort> T newInput(String name, LogicalPortFactory<T> factory, boolean optional)
T
- the type of the portname
- the name of the port, must be unique within the operator.factory
- the factory, determines the type of the portoptional
- whether the port is optionalLogicalOperator
protected final RecordPort newRecordOutput(String name)
name
- the name of the port, must be unique within the operator.LogicalOperator
protected final <T extends LogicalPort> T newOutput(String name, LogicalPortFactory<T> factory)
T
- the type of the portname
- the name of the port, must be unique within the operator.factory
- the factory, determines the type of the portLogicalOperator
Copyright © 2021 Actian Corporation. All rights reserved.