com.pervasive.datarush.operators.io.paraccel

Class MatrixSinkInitializeWorker

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.StreamingOperator

com.pervasive.datarush.operators.ExecutableOperator

com.pervasive.datarush.operators.io.paraccel.InitializeWorkerBase<Void>

com.pervasive.datarush.operators.io.paraccel.MatrixSinkInitializeWorker

All Implemented Interfaces:

LogicalOperator

public class MatrixSinkInitializeWorker
extends InitializeWorkerBase<Void>

Field Summary

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

endPortRange, logger, retryCount, startPortRange, table, targetColumns, traceLevel, workerParallelism

Constructor Summary

Constructors

Constructor and Description
MatrixSinkInitializeWorker(String coordHost, int coordPort, RecordTokenType inputType, com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo)

Method Summary

Modifier and Type	Method and Description
protected void	cancel(Void state)
protected void	checkRetryState(Void invokerRef)
protected Void	createInvoker(ExecutionContext ctx, String invokerId)
String	getCoordHost()
int	getCoordPort()
RecordTokenType	getInputType()
com.pervasive.datarush.operators.io.paraccel.TableInfo	getTableInfo()
protected void	initializeProtocol(String invokerId, Void invoker, InetAddress sliceRegHost, int sliceRegPort, com.pervasive.datarush.operators.io.paraccel.SliceInfo sliceInfo, int maxConnections)
void	setCoordHost(String coordHost)
void	setCoordPort(int coordPort)
void	setInputType(RecordTokenType inputType)
void	setTableInfo(com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo)

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

computeMetadata, execute, getEndPortRange, getRetryCount, getSliceIdentifiers, getSliceOutput, getStartPortRange, getTable, getTargetColumns, getTimeoutInterval, getTraceLevel, getWorkerParallelism, setEndPortRange, setRetryCount, setSliceIdentifiers, setStartPortRange, setTable, setTargetColumns, setTimeoutInterval, setTraceLevel, setWorkerParallelism

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

MatrixSinkInitializeWorker

public MatrixSinkInitializeWorker(String coordHost,
                                  int coordPort,
                                  RecordTokenType inputType,
                                  com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo)

Method Detail

getCoordHost

public String getCoordHost()

setCoordHost

public void setCoordHost(String coordHost)

getCoordPort

public int getCoordPort()

setCoordPort

public void setCoordPort(int coordPort)

initializeProtocol

protected void initializeProtocol(String invokerId,
                                  Void invoker,
                                  InetAddress sliceRegHost,
                                  int sliceRegPort,
                                  com.pervasive.datarush.operators.io.paraccel.SliceInfo sliceInfo,
                                  int maxConnections)

Specified by:

initializeProtocol in class InitializeWorkerBase<Void>

createInvoker

protected Void createInvoker(ExecutionContext ctx,
                             String invokerId)

Specified by:

createInvoker in class InitializeWorkerBase<Void>

getInputType

public RecordTokenType getInputType()

setInputType

public void setInputType(RecordTokenType inputType)

getTableInfo

public com.pervasive.datarush.operators.io.paraccel.TableInfo getTableInfo()

setTableInfo

public void setTableInfo(com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo)

checkRetryState

protected void checkRetryState(Void invokerRef)

Specified by:

checkRetryState in class InitializeWorkerBase<Void>

cancel

protected void cancel(Void state)

Specified by:

cancel in class InitializeWorkerBase<Void>