protected MatrixOperatorBase.Workers<Void> |
MatrixSink.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
protected abstract MatrixOperatorBase.Workers<ExecState> |
MatrixOperatorBase.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
protected MatrixOperatorBase.Workers<com.pervasive.datarush.operators.io.paraccel.ODIInvoker> |
LoadMatrix.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |