Package org.apache.flink.state.api.input

Class SourceBuilder

java.lang.Object

org.apache.flink.state.api.input.SourceBuilder

@Internal
public final class SourceBuilder
extends Object

A utility for constructing InputFormat based sources that are marked as BOUNDED.

Field Summary

Fields

Modifier and Type	Field	Description
static String	SOURCE_NAME

Method Summary

Modifier and Type	Method	Description
static <OUT> DataStreamSource<OUT>	fromFormat(StreamExecutionEnvironment env, InputFormat<OUT,?> inputFormat, TypeInformation<OUT> typeInfo)	Creates a new source that is bounded.

Methods inherited from class java.lang.Object

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

Field Detail

SOURCE_NAME

public static final String SOURCE_NAME

See Also:

Constant Field Values

Method Detail

fromFormat

public static <OUT> DataStreamSource<OUT> fromFormat(StreamExecutionEnvironment env,
                                                     InputFormat<OUT,?> inputFormat,
                                                     TypeInformation<OUT> typeInfo)

Creates a new source that is bounded.

Type Parameters:

OUT - The output type.

Parameters:

env - The stream execution environment.

inputFormat - The input source to consume.

typeInfo - The type of the output.

Returns:

A source that is bounded.