public abstract class BatchOperator<T extends BatchOperator<T>> extends AlgoOperator<T>
This class extends AlgoOperator to support data transmission between BatchOperators.
ML_ENVIRONMENT_ID| Constructor and Description |
|---|
BatchOperator() |
BatchOperator(Params params)
The constructor of BatchOperator with
Params. |
| Modifier and Type | Method and Description |
|---|---|
protected static BatchOperator<?> |
checkAndGetFirst(BatchOperator<?>... inputs) |
static BatchOperator<?> |
fromTable(Table table)
create a new BatchOperator from table.
|
<B extends BatchOperator<?>> |
link(B next)
Link to another
BatchOperator. |
abstract T |
linkFrom(BatchOperator<?>... inputs)
Link from others
BatchOperator. |
checkMinOpSize, checkOpSize, getColNames, getColTypes, getOutput, getParams, getSchema, getSideOutputColNames, getSideOutputColTypes, getSideOutputs, setOutput, setSideOutputs, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetMLEnvironmentId, setMLEnvironmentIdget, setpublic <B extends BatchOperator<?>> B link(B next)
BatchOperator.
Link the next BatchOperator using this BatchOperator as its input.
For example:
BatchOperator a = ...;
BatchOperator b = ...;
BatchOperator c = a.link(b)
The BatchOperator c in the above code is the same instance as b
which takes a as its input. Note that BatchOperator b will be
changed to link from BatchOperator a.
B - type of BatchOperator returnednext - The operator that will be modified to add this operator to its input.linkFrom(BatchOperator[])public abstract T linkFrom(BatchOperator<?>... inputs)
BatchOperator.
Link this object to BatchOperator using the BatchOperators as its input.
For example:
BatchOperator a = ...;
BatchOperator b = ...;
BatchOperator c = ...;
BatchOperator d = c.linkFrom(a, b)
The d in the above code is the same instance as BatchOperator c
which takes both a and b as its input.
note: It is not recommended to linkFrom itself or linkFrom the same group inputs twice.
inputs - the linked inputspublic static BatchOperator<?> fromTable(Table table)
table - the input tableprotected static BatchOperator<?> checkAndGetFirst(BatchOperator<?>... inputs)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.