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