public abstract class MatrixOperatorBase<ExecState> extends CompositeOperator implements RecordSinkOperator
Modifier and Type | Class and Description |
---|---|
protected static class |
MatrixOperatorBase.Pair<A,B> |
protected static class |
MatrixOperatorBase.Workers<E> |
Modifier and Type | Field and Description |
---|---|
static int |
END_PORT_RANGE |
protected String |
host |
protected int |
logFrequency |
protected static org.apache.commons.logging.Log |
logger |
protected int |
maxConnections |
protected int |
retryCount |
static int |
START_PORT_RANGE |
protected int |
timeoutInterval |
Constructor and Description |
---|
MatrixOperatorBase() |
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext ctx)
Compose the body of this operator.
|
protected abstract MatrixOperatorBase.Workers<ExecState> |
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) |
String |
getHost()
Get the server host name property.
|
RecordPort |
getInput()
Gets the record port providing the input data to the sink.
|
int |
getMaxConnections()
Get the max connections property.
|
protected abstract MatrixOperatorBase.Pair<Integer,Integer> |
portRange() |
protected abstract Map<String,String> |
renameMapping() |
protected abstract MatrixOperatorBase.Pair<com.pervasive.datarush.operators.io.paraccel.TableInfo,List<com.pervasive.datarush.operators.io.paraccel.SliceIdentifier>> |
schemaAndSliceInfo() |
void |
setHost(String hostName)
Set the host name property.
|
void |
setMaxConnections(int maxConnections)
Set the max connections property.
|
protected abstract boolean |
skipCompose() |
protected abstract void |
validateExtensions() |
protected void |
validatePortRange(String startPortName,
int startPort,
int endPort) |
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disableParallelism, getInputPorts, getOutputPorts
public static final int START_PORT_RANGE
public static final int END_PORT_RANGE
protected String host
protected int logFrequency
protected int retryCount
protected int timeoutInterval
protected int maxConnections
protected static final org.apache.commons.logging.Log logger
public RecordPort getInput()
RecordSinkOperator
getInput
in interface RecordSinkOperator
getInput
in interface SinkOperator<RecordPort>
public String getHost()
public void setHost(String hostName)
hostName
- Matrix server host namepublic int getMaxConnections()
public void setMaxConnections(int maxConnections)
Note that the number of connections is limited by setting the parallelism of the data worker operator
of the LoadMatrix
instance. This may incur the cost of data redistribution to match the
parallelism specified.
maxConnections
- maximum number of connections to use for data transferprotected void compose(CompositionContext ctx)
CompositeOperator
OperatorComposable.add(O)
OperatorComposable.connect(P, P)
. This includes
connections from the composite's input ports to sub-operators, connections between sub-operators, and
connections from sub-operators output ports to the composite's output portscompose
in class CompositeOperator
ctx
- the contextprotected abstract boolean skipCompose()
protected void validatePortRange(String startPortName, int startPort, int endPort)
protected abstract MatrixOperatorBase.Workers<ExecState> 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 void validateExtensions()
protected abstract MatrixOperatorBase.Pair<com.pervasive.datarush.operators.io.paraccel.TableInfo,List<com.pervasive.datarush.operators.io.paraccel.SliceIdentifier>> schemaAndSliceInfo()
protected abstract MatrixOperatorBase.Pair<Integer,Integer> portRange()
Copyright © 2016 Actian Corporation. All rights reserved.