KeyGroupStatePartitionStreamProvider (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.state.StatePartitionStreamProvider
- - org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider

```
@PublicEvolving
public class KeyGroupStatePartitionStreamProvider
extends StatePartitionStreamProvider
```
This class provides access to an input stream that contains state data for one key group and the key group id.

Constructor Summary

Constructors
Constructor	Description
`KeyGroupStatePartitionStreamProvider(InputStream stream, int keyGroupId)`
`KeyGroupStatePartitionStreamProvider(IOException creationException, int keyGroupId)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

int getKeyGroupId()
Returns the key group that corresponds to the data in the provided stream.
- Methods inherited from class org.apache.flink.runtime.state.StatePartitionStreamProvider
  getStream
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KeyGroupStatePartitionStreamProvider

public KeyGroupStatePartitionStreamProvider(IOException creationException,
                                            int keyGroupId)

KeyGroupStatePartitionStreamProvider

public KeyGroupStatePartitionStreamProvider(InputStream stream,
                                            int keyGroupId)

Method Detail
- getKeyGroupId
```
public int getKeyGroupId()
```
  Returns the key group that corresponds to the data in the provided stream.