final class LagColumnStreamableOperator extends StreamableOperator
|Constructor and Description|
|Modifier and Type||Method and Description|
Performs the execution on the input and (possibly) produces the output.
loadInternals, runIntermediate, saveInternals
BufferedDataTable execute(BufferedDataTable table, ExecutionContext exec) throws Exception
public void runFinal(PortInput inputs, PortOutput outputs, ExecutionContext exec) throws Exception
inputsargument must be cast to specific classes. The class depends on the
InputPortRoleof the corresponding port (as described by
NodeModel.getInputPortRoles(). If it is streamable (which can only be true for data ports), then the object can be cast to
RowInput. If it's non streamable, then it's an instance of
outputs argument contains non-null output handles
in either of the two cases: (i) all of the inputs are non-distributable
(only one instance of a streamable operator that generates the final
output) or (ii) the corresponding output is distributable
NodeModel.getOutputPortRoles(). Non-null output handles need
to be filled by this method.
KNIME GmbH, Konstanz, Germany
You may not modify, publish, transmit, transfer or sell, reproduce, create derivative works from, distribute, perform, display, or in any way exploit any of the content, in whole or in part, except as otherwise expressly permitted in writing by the copyright owner or as specified in the license file distributed with this product.