protected abstract static class AbstractWriteToJDBC.AbstractWriteToJDBCWorker extends ExecutableOperator
Constructor and Description |
---|
AbstractWriteToJDBCWorker(JDBCConnector connector,
String onEveryRecordStatement,
AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties) |
Modifier and Type | Method and Description |
---|---|
protected ExecutableOperator |
cloneForExecution()
Performs a deep copy of the operator for execution.
|
protected void |
computeMetadata(StreamingMetadataContext ctx)
Implementations must adhere to the following contracts
|
protected abstract AbstractWriteToJDBC.AbstractWriteHelper |
createWriteHelper(JDBCConnector connector,
RecordPort input,
RecordPort output,
ExecutionContext ctx,
String onEveryRecordStatement,
AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties) |
void |
execute(ExecutionContext ctx)
Executes the operator.
|
JDBCConnector |
getConnector() |
DoneSignalPort |
getDoneSignal() |
RecordPort |
getInput() |
String |
getOnEveryRecordStatement() |
abstract RecordPort |
getOutput() |
RecordTokenType |
getOutputType(RecordTokenType inputType) |
AbstractWriteToJDBC.SqlWriteProperties |
getSqlWriteProperties() |
DoneSignalPort |
getStartSignal() |
getNumInputCopies, getPortSettings, handleInactiveOutput
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public AbstractWriteToJDBCWorker(JDBCConnector connector, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties)
public JDBCConnector getConnector()
public String getOnEveryRecordStatement()
public AbstractWriteToJDBC.SqlWriteProperties getSqlWriteProperties()
public DoneSignalPort getStartSignal()
public DoneSignalPort getDoneSignal()
public RecordPort getInput()
public abstract RecordPort getOutput()
public RecordTokenType getOutputType(RecordTokenType inputType)
protected ExecutableOperator cloneForExecution()
ExecutableOperator
cloneForExecution
in class ExecutableOperator
protected void computeMetadata(StreamingMetadataContext ctx)
StreamingOperator
StreamingMetadataContext.parallelize(ParallelismStrategy)
.
RecordPort#setRequiredDataOrdering
, otherwise data may arrive in any order.
RecordPort#setRequiredDataDistribution
, otherwise data will arrive in an unspecified partial distribution
.
RecordPort#getSourceDataDistribution
and RecordPort#getSourceDataOrdering
. These should be
viewed as a hints to help chose a more efficient algorithm. In such cases, though, operators must
still declare data ordering and data distribution requirements; otherwise there is no guarantee that
data will arrive sorted/distributed as required.
RecordPort#setType
.RecordPort#setOutputDataOrdering
RecordPort#setOutputDataDistribution
AbstractModelPort#setMergeHandler
.MergeModel
is a convenient, re-usable model reducer, parameterized with
a merge-handler.
SimpleModelPort
's have no associated metadata and therefore there is
never any output metadata to declare. PMMLPort
's, on the other hand,
do have associated metadata. For all PMMLPorts, implementations must declare
the following:
PMMLPort.setPMMLModelSpec
.
computeMetadata
in class StreamingOperator
ctx
- the contextpublic void execute(ExecutionContext ctx)
ExecutableOperator
execute
in class ExecutableOperator
ctx
- context in which to lookup physical ports bound to logical portsprotected abstract AbstractWriteToJDBC.AbstractWriteHelper createWriteHelper(JDBCConnector connector, RecordPort input, RecordPort output, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties)
Copyright © 2016 Actian Corporation. All rights reserved.