Package org.apache.flink.state.api

Class OperatorTransformation

java.lang.Object

org.apache.flink.state.api.OperatorTransformation

@PublicEvolving
public final class OperatorTransformation
extends Object

This class provides the entry point for building StateBootstrapTransformations, which represents procedures to bootstrap new operator states with a given DataStream.

Example usage

 DataStream<StateData> stateData = ...;

 // to bootstrap non-keyed state:
 StateBootstrapTransformation<StateData> nonKeyedStateBootstrap = OperatorTransformation
     .bootstrapWith(stateData)
     .transform(new StateBootstrapFunction<StateData>() {...})

 // to bootstrap keyed state:
 StateBootstrapTransformation<StateData> keyedStateBootstrap = OperatorTransformation
     .bootstrapWith(stateData)
     .keyBy(new KeySelector<StateData, KeyType>() {...})
     .transform(new KeyedStateBootstrapFunction<KeyType, StateData>() {...})
 

The code example above demonstrates how to create BootstrapTransformations for non-keyed and keyed state. The built bootstrap transformations can then used with a SavepointWriter.

See Also:

OneInputStateTransformation, KeyedStateTransformation, StateBootstrapTransformation

Method Summary

Modifier and Type	Method	Description
static <T> OneInputOperatorTransformation<T>	bootstrapWith(org.apache.flink.api.java.DataSet<T> dataSet)	Deprecated. use bootstrapWith(DataStream) to bootstrap a savepoint using the data stream api under batch execution.
static <T> OneInputOperatorTransformation<T>	bootstrapWith(org.apache.flink.api.java.DataSet<T> dataSet, long checkpointId)	Deprecated. use bootstrapWith(DataStream) to bootstrap a savepoint using the data stream api under batch execution.
static <T> OneInputStateTransformation<T>	bootstrapWith(org.apache.flink.streaming.api.datastream.DataStream<T> stream)	Create a new OneInputStateTransformation from a DataStream.
static <T> OneInputStateTransformation<T>	bootstrapWith(org.apache.flink.streaming.api.datastream.DataStream<T> stream, long checkpointId)	Create a new OneInputStateTransformation from a DataStream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

bootstrapWith

@Deprecated
public static <T> OneInputOperatorTransformation<T> bootstrapWith(org.apache.flink.api.java.DataSet<T> dataSet)

Deprecated.

use bootstrapWith(DataStream) to bootstrap a savepoint using the data stream api under batch execution.

Create a new OperatorTransformation from a DataSet.

Type Parameters:

T - The type of the input.

Parameters:

dataSet - A dataset of elements.

Returns:

A OneInputOperatorTransformation.

bootstrapWith

@Deprecated
public static <T> OneInputOperatorTransformation<T> bootstrapWith(org.apache.flink.api.java.DataSet<T> dataSet,
                                                                  long checkpointId)

Deprecated.

use bootstrapWith(DataStream) to bootstrap a savepoint using the data stream api under batch execution.

Create a new OperatorTransformation from a DataSet.

Type Parameters:

T - The type of the input.

Parameters:

dataSet - A dataset of elements.

checkpointId - checkpoint ID.

Returns:

A OneInputOperatorTransformation.

bootstrapWith

public static <T> OneInputStateTransformation<T> bootstrapWith(org.apache.flink.streaming.api.datastream.DataStream<T> stream)

Create a new OneInputStateTransformation from a DataStream.

Type Parameters:

T - The type of the input.

Parameters:

stream - A data stream of elements.

Returns:

A OneInputStateTransformation.

bootstrapWith

public static <T> OneInputStateTransformation<T> bootstrapWith(org.apache.flink.streaming.api.datastream.DataStream<T> stream,
                                                               long checkpointId)

Create a new OneInputStateTransformation from a DataStream.

Type Parameters:

T - The type of the input.

Parameters:

stream - A data stream of elements.

checkpointId - checkpoint ID.

Returns:

A OneInputStateTransformation.