public final class TableSourceStreamOp extends StreamOperator<TableSourceStreamOp>
ML_ENVIRONMENT_ID
Constructor and Description |
---|
TableSourceStreamOp(Table table) |
Modifier and Type | Method and Description |
---|---|
TableSourceStreamOp |
linkFrom(StreamOperator<?>... inputs)
Link from others
StreamOperator . |
checkAndGetFirst, fromTable, link
checkMinOpSize, checkOpSize, getColNames, getColTypes, getOutput, getParams, getSchema, getSideOutputColNames, getSideOutputColTypes, getSideOutputs, setOutput, setSideOutputs, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getMLEnvironmentId, setMLEnvironmentId
get, set
public TableSourceStreamOp(Table table)
public TableSourceStreamOp linkFrom(StreamOperator<?>... inputs)
StreamOperator
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.
linkFrom
in class StreamOperator<TableSourceStreamOp>
inputs
- the linked inputsCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.