com.pervasive.datarush.operators.io.paraccel

Class MatrixSinkCompletionWorker

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.StreamingOperator

com.pervasive.datarush.operators.ExecutableOperator

com.pervasive.datarush.operators.io.paraccel.CompletionWorkerBase

com.pervasive.datarush.operators.io.paraccel.MatrixSinkCompletionWorker

All Implemented Interfaces:

LogicalOperator

public class MatrixSinkCompletionWorker
extends CompletionWorkerBase

Field Summary

Fields inherited from class com.pervasive.datarush.operators.io.paraccel.CompletionWorkerBase

logger

Constructor Summary

Constructors

Constructor and Description
MatrixSinkCompletionWorker()

Method Summary

Modifier and Type	Method and Description
protected void	execute(ExecutionContext ctx) Executes the operator.

Methods inherited from class com.pervasive.datarush.operators.io.paraccel.CompletionWorkerBase

computeMetadata, getDoneSignalPort, waitForDataWorkers

Methods inherited from class com.pervasive.datarush.operators.ExecutableOperator

cloneForExecution, getNumInputCopies, getPortSettings, handleInactiveOutput

Methods inherited from class com.pervasive.datarush.operators.AbstractLogicalOperator

disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError

Methods inherited from class java.lang.Object

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

Constructor Detail

MatrixSinkCompletionWorker

public MatrixSinkCompletionWorker()

Method Detail

execute

protected void execute(ExecutionContext ctx)

Description copied from class: ExecutableOperator

Executes the operator. Implementations should adhere to the following contracts:

1. Following execution, all input ports must be at end-of-data.
2. Following execution, all output ports must be at end-of-data.

Specified by:

execute in class ExecutableOperator

Parameters:

ctx - context in which to lookup physical ports bound to logical ports