Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Method and Description |
---|---|
ShardedConnection |
DbBackendConfig.createShardedConnection()
Creates a new
ShardedConnection using the set parameters. |
ShardedConnection |
DbStateBackend.getConnections()
Get the database connections maintained by the backend.
|
Constructor and Description |
---|
LazyDbValueState(String kvStateId,
boolean compact,
ShardedConnection cons,
DbBackendConfig conf,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ValueStateDescriptor<V> stateDesc)
Constructor to initialize the
LazyDbValueState the first time the
job starts. |
LazyDbValueState(String kvStateId,
boolean compact,
ShardedConnection cons,
DbBackendConfig conf,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ValueStateDescriptor<V> stateDesc,
long nextTs,
long lastCompactedTs)
Initialize the
LazyDbValueState from a snapshot. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.