@PublicEvolving public class KeyGroupStatePartitionStreamProvider extends StatePartitionStreamProvider
Constructor and Description |
---|
KeyGroupStatePartitionStreamProvider(InputStream stream,
int keyGroupId) |
KeyGroupStatePartitionStreamProvider(IOException creationException,
int keyGroupId) |
Modifier and Type | Method and Description |
---|---|
int |
getKeyGroupId()
Returns the key group that corresponds to the data in the provided stream.
|
getStream
public KeyGroupStatePartitionStreamProvider(IOException creationException, int keyGroupId)
public KeyGroupStatePartitionStreamProvider(InputStream stream, int keyGroupId)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.