org.apache.flink.runtime.state

Class StatePartitionStreamProvider

java.lang.Object

org.apache.flink.runtime.state.StatePartitionStreamProvider

Direct Known Subclasses:

KeyGroupStatePartitionStreamProvider

@PublicEvolving
public class StatePartitionStreamProvider
extends Object

This class provides access to input streams that contain data of one state partition of a partitionable state.

TODO use bounded stream that fail fast if the limit is exceeded on corrupted reads.

Constructor Summary

Constructors

Constructor and Description
StatePartitionStreamProvider(InputStream stream)
StatePartitionStreamProvider(IOException creationException)

Method Summary

Modifier and Type	Method and Description
InputStream	getStream() Returns a stream with the data of one state partition.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatePartitionStreamProvider

public StatePartitionStreamProvider(IOException creationException)

StatePartitionStreamProvider

public StatePartitionStreamProvider(InputStream stream)

Method Detail

getStream

public InputStream getStream()
                      throws IOException

Returns a stream with the data of one state partition.

Throws:

IOException