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