public final class SumOfSquares extends ExecutableOperator
Note that the fields must be of type double
or be
assignable to a double
type.
Constructor and Description |
---|
SumOfSquares()
Default constructor.
|
SumOfSquares(List<String> fieldNames)
Construct with the given field names.
|
Modifier and Type | Method and Description |
---|---|
protected void |
computeMetadata(StreamingMetadataContext ctx)
Implementations must adhere to the following contracts
|
protected void |
execute(ExecutionContext ctx)
Compute the inner product for each distributed dataflow.
|
List<String> |
getFieldNames()
Get the list of field names to apply sum of squares.
|
RecordPort |
getInput()
Get the input port for this operator.
|
SimpleModelPort<org.apache.commons.math.linear.Array2DRowRealMatrix> |
getOutput()
Get the output model port of this operator.
|
void |
setFieldNames(List<String> fieldNames)
Set the list of fields to apply sum of squares.
|
cloneForExecution, getNumInputCopies, getPortSettings, handleInactiveOutput
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public SumOfSquares()
setFieldNames(List)
.public RecordPort getInput()
public SimpleModelPort<org.apache.commons.math.linear.Array2DRowRealMatrix> getOutput()
public List<String> getFieldNames()
public void setFieldNames(List<String> fieldNames)
double
type.fieldNames
- field namesprotected 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 contextprotected void execute(ExecutionContext ctx)
execute
in class ExecutableOperator
ctx
- context in which to lookup physical ports bound to logical portsCopyright © 2021 Actian Corporation. All rights reserved.