public final class DoneSignalPort extends AbstractModelPort<Void>
LogicalPort.Direction
Modifier and Type | Field and Description |
---|---|
static AbstractModelPortFactory<Void,DoneSignalPort> |
FACTORY
The factory for DoneSignalPorts
|
Modifier and Type | Method and Description |
---|---|
LogicalPortFactory<? extends AbstractModelPort<?>> |
getFactory()
Returns the factory that knows how to create ports of this type
|
AbstractModelPortMetadata |
getMetadata(Void model)
Returns the metadata associate with the model.
|
Class<? extends PortMetadata> |
getMetadataType()
Returns the class of metadata that this port uses
|
static DoneSignalPort |
getOutput(LogicalOperator op)
Returns the done signal port from the given operator if it defines one, throwing
an exception if none found
|
void |
signalDone(ExecutionContext ctx)
Signals downstream operators that we are done
|
void |
waitDone(ExecutionContext ctx)
Waits until upstream operator has sent the done signal
|
getModel, getModelClass, getStorageHandler, setMergeHandler, setModel
getDirection, getName, getOwner, isOptional, toString
public static final AbstractModelPortFactory<Void,DoneSignalPort> FACTORY
public AbstractModelPortMetadata getMetadata(Void model)
AbstractModelPort
getMetadata
in class AbstractModelPort<Void>
model
- the model objectpublic LogicalPortFactory<? extends AbstractModelPort<?>> getFactory()
LogicalPort
getFactory
in class AbstractModelPort<Void>
public Class<? extends PortMetadata> getMetadataType()
LogicalPort
getMetadataType
in class LogicalPort
public void signalDone(ExecutionContext ctx)
ctx
- the execution contextpublic void waitDone(ExecutionContext ctx)
ctx
- the execution contextpublic static DoneSignalPort getOutput(LogicalOperator op)
op
- the operatorCopyright © 2024 Actian Corporation. All rights reserved.