Package | Description |
---|---|
org.apache.flink.streaming.api.runners.python.beam.state |
Modifier and Type | Class and Description |
---|---|
class |
BeamKeyedStateStore
A
BeamStateStore that returns keyed states based on BeamFnApi.StateRequest . |
class |
BeamOperatorStateStore
A
BeamStateStore that returns operator states based on BeamFnApi.StateRequest . |
Modifier and Type | Method and Description |
---|---|
static BeamStateStore |
BeamStateStore.unsupported() |
Constructor and Description |
---|
BeamStateRequestHandler(BeamStateStore keyedStateStore,
BeamStateStore operatorStateStore,
BeamStateHandler<ListState<byte[]>> bagStateHandler,
BeamStateHandler<MapState<ByteArrayWrapper,byte[]>> mapStateHandler) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.