Package | Description |
---|---|
org.apache.flink.ml.operator.stream | |
org.apache.flink.ml.operator.stream.source | |
org.apache.flink.ml.pipeline |
Modifier and Type | Class and Description |
---|---|
class |
StreamOperator<T extends StreamOperator<T>>
Base class of stream algorithm operators.
|
Modifier and Type | Method and Description |
---|---|
<S extends StreamOperator<?>> |
StreamOperator.link(S next)
Link to another
StreamOperator . |
Modifier and Type | Method and Description |
---|---|
protected static StreamOperator<?> |
StreamOperator.checkAndGetFirst(StreamOperator<?>... inputs) |
static StreamOperator<?> |
StreamOperator.fromTable(Table table)
create a new StreamOperator from table.
|
Modifier and Type | Method and Description |
---|---|
protected static StreamOperator<?> |
StreamOperator.checkAndGetFirst(StreamOperator<?>... inputs) |
abstract T |
StreamOperator.linkFrom(StreamOperator<?>... inputs)
Link from others
StreamOperator . |
Modifier and Type | Class and Description |
---|---|
class |
TableSourceStreamOp
Transform the Table to SourceStreamOp.
|
Modifier and Type | Method and Description |
---|---|
TableSourceStreamOp |
TableSourceStreamOp.linkFrom(StreamOperator<?>... inputs) |
Modifier and Type | Method and Description |
---|---|
protected abstract StreamOperator |
TransformerBase.transform(StreamOperator input)
Applies the transformer on the input streaming data from StreamOperator, and returns the streaming result data
with StreamOperator.
|
Modifier and Type | Method and Description |
---|---|
protected M |
EstimatorBase.fit(StreamOperator input)
Online learning and produce
ModelBase series which fit the streaming records from the given StreamOperator . |
protected abstract StreamOperator |
TransformerBase.transform(StreamOperator input)
Applies the transformer on the input streaming data from StreamOperator, and returns the streaming result data
with StreamOperator.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.