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

Class UnionStateInputFormat<OT>

java.lang.Object

org.apache.flink.api.common.io.RichInputFormat<OT,OperatorStateInputSplit>

org.apache.flink.state.api.input.UnionStateInputFormat<OT>

Type Parameters:

OT - The generic type of the state

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.io.InputFormat<OT,OperatorStateInputSplit>, org.apache.flink.core.io.InputSplitSource<OperatorStateInputSplit>

@Internal
public class UnionStateInputFormat<OT>
extends org.apache.flink.api.common.io.RichInputFormat<OT,OperatorStateInputSplit>

Input format for reading operator union state.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
UnionStateInputFormat(org.apache.flink.runtime.checkpoint.OperatorState operatorState, org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.state.StateBackend backend, org.apache.flink.api.common.state.ListStateDescriptor<OT> descriptor)	Creates an input format for reading union state from an operator in a savepoint.

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(org.apache.flink.configuration.Configuration parameters)
OperatorStateInputSplit[]	createInputSplits(int minNumSplits)
protected Iterable<OT>	getElements(org.apache.flink.runtime.state.OperatorStateBackend restoredBackend)
org.apache.flink.core.io.InputSplitAssigner	getInputSplitAssigner(OperatorStateInputSplit[] inputSplits)
org.apache.flink.api.common.io.statistics.BaseStatistics	getStatistics(org.apache.flink.api.common.io.statistics.BaseStatistics cachedStatistics)
OT	nextRecord(OT reuse)
void	open(OperatorStateInputSplit split)
boolean	reachedEnd()

Methods inherited from class org.apache.flink.api.common.io.RichInputFormat

closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

UnionStateInputFormat

public UnionStateInputFormat(org.apache.flink.runtime.checkpoint.OperatorState operatorState,
                             org.apache.flink.configuration.Configuration configuration,
                             @Nullable
                             org.apache.flink.runtime.state.StateBackend backend,
                             org.apache.flink.api.common.state.ListStateDescriptor<OT> descriptor)

Creates an input format for reading union state from an operator in a savepoint.

Parameters:

operatorState - The state to be queried.

configuration - The cluster configuration for restoring the backend.

backend - The state backend used to restore the state.

descriptor - The descriptor for this state, providing a name and serializer.

Method Detail

getElements

protected final Iterable<OT> getElements(org.apache.flink.runtime.state.OperatorStateBackend restoredBackend)
                                  throws Exception

Throws:

Exception

configure

public void configure(org.apache.flink.configuration.Configuration parameters)

getStatistics

public org.apache.flink.api.common.io.statistics.BaseStatistics getStatistics(org.apache.flink.api.common.io.statistics.BaseStatistics cachedStatistics)

getInputSplitAssigner

public org.apache.flink.core.io.InputSplitAssigner getInputSplitAssigner(OperatorStateInputSplit[] inputSplits)

createInputSplits

public OperatorStateInputSplit[] createInputSplits(int minNumSplits)

open

public void open(OperatorStateInputSplit split)
          throws IOException

Throws:

IOException

close

public void close()

reachedEnd

public boolean reachedEnd()

nextRecord

public OT nextRecord(OT reuse)