Modifier and Type | Interface and Description |
---|---|
interface |
Stage<T extends Stage<T>>
Base class for a node in a Pipeline or Graph.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AlgoOperator<T extends AlgoOperator<T>>
An AlgoOperator takes a list of tables as inputs and produces a list of tables as results.
|
interface |
Estimator<E extends Estimator<E,M>,M extends Model<M>>
Estimators are responsible for training and generating Models.
|
interface |
Model<T extends Model<T>>
A Model is typically generated by invoking
Estimator.fit(Table...) . |
interface |
Transformer<T extends Transformer<T>>
A Transformer is an AlgoOperator with the semantic difference that it encodes the Transformation
logic, such that a record in the output typically corresponds to one record in the input.
|
Modifier and Type | Class and Description |
---|---|
class |
Graph
A Graph acts as an Estimator.
|
class |
GraphModel
A GraphModel acts as a Model.
|
class |
Pipeline
A Pipeline acts as an Estimator.
|
class |
PipelineModel
A PipelineModel acts as a Model.
|
Modifier and Type | Field and Description |
---|---|
Stage<?> |
GraphNode.stage |
Constructor and Description |
---|
GraphNode(int nodeId,
Stage<?> stage,
GraphNode.StageType stageType,
TableId[] estimatorInputIds,
TableId[] algoOpInputIds,
TableId[] outputIds,
TableId[] inputModelDataIds,
TableId[] outputModelDataIds) |
Constructor and Description |
---|
Pipeline(List<Stage<?>> stages) |
PipelineModel(List<Stage<?>> stages) |
Modifier and Type | Class and Description |
---|---|
class |
Knn
An Estimator which implements the KNN algorithm.
|
class |
KnnModel
A Model which classifies data using the model data computed by
Knn . |
Modifier and Type | Class and Description |
---|---|
class |
LogisticRegression
An Estimator which implements the logistic regression algorithm.
|
class |
LogisticRegressionModel
A Model which classifies data using the model data computed by
LogisticRegression . |
Modifier and Type | Class and Description |
---|---|
class |
NaiveBayes
An Estimator which implements the naive bayes classification algorithm.
|
class |
NaiveBayesModel
A Model which classifies data using the model data computed by
NaiveBayes . |
Modifier and Type | Class and Description |
---|---|
class |
KMeans
An Estimator which implements the k-means clustering algorithm.
|
class |
KMeansModel
A Model which clusters data into k clusters using the model data computed by
KMeans . |
Modifier and Type | Class and Description |
---|---|
class |
OneHotEncoder
An Estimator which implements the one-hot encoding algorithm.
|
class |
OneHotEncoderModel
A Model which encodes data into one-hot format using the model data computed by
OneHotEncoder . |
Modifier and Type | Method and Description |
---|---|
static <T extends Stage<T>> |
ReadWriteUtils.loadStageParam(String path)
Loads the stage with the saved parameters from the given path.
|
Modifier and Type | Method and Description |
---|---|
static Stage<?> |
ReadWriteUtils.loadGraph(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String path,
String expectedClassName)
Loads a Graph or GraphModel from the given path.
|
static Stage<?> |
ReadWriteUtils.loadStage(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String path)
Loads the stage from the given path by invoking the static load() method of the stage.
|
Modifier and Type | Method and Description |
---|---|
static List<Stage<?>> |
ReadWriteUtils.loadPipeline(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String path,
String expectedClassName)
Loads the stages of a Pipeline or PipelineModel from the given path.
|
Modifier and Type | Method and Description |
---|---|
static void |
ReadWriteUtils.saveGraph(Stage<?> graph,
GraphData graphData,
String path)
Saves a Graph or GraphModel with the given GraphData to the given path.
|
static void |
ReadWriteUtils.saveMetadata(Stage<?> stage,
String path)
Saves the metadata of the given stage to a file named `metadata` under the given path.
|
static void |
ReadWriteUtils.saveMetadata(Stage<?> stage,
String path,
Map<String,?> extraMetadata)
Saves the metadata of the given stage and the extra metadata to a file named `metadata` under
the given path.
|
static void |
ReadWriteUtils.savePipeline(Stage<?> pipeline,
List<Stage<?>> stages,
String path)
Saves a Pipeline or PipelineModel with the given list of stages to the given path.
|
static <T> void |
ReadWriteUtils.setParam(Stage<?> stage,
Param<T> param,
Object value) |
static void |
ReadWriteUtils.updateExistingParams(Stage<?> stage,
Map<Param<?>,Object> paramOverrides) |
Modifier and Type | Method and Description |
---|---|
static void |
ReadWriteUtils.savePipeline(Stage<?> pipeline,
List<Stage<?>> stages,
String path)
Saves a Pipeline or PipelineModel with the given list of stages to the given path.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.