Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Method and Description |
---|---|
DbBackendConfig |
DbStateBackend.getConfiguration()
Get the backend configuration object.
|
Modifier and Type | Method and Description |
---|---|
void |
DbAdapter.insertBatch(String stateId,
DbBackendConfig conf,
Connection con,
PreparedStatement insertStatement,
long checkpointTimestamp,
List<Tuple2<byte[],byte[]>> toInsert)
Insert a list of Key-Value pairs into the database.
|
void |
MySqlAdapter.insertBatch(String stateId,
DbBackendConfig conf,
Connection con,
PreparedStatement insertStatement,
long checkpointTs,
List<Tuple2<byte[],byte[]>> toInsert) |
Constructor and Description |
---|
DbStateBackend(DbBackendConfig backendConfig)
Create a new
DbStateBackend using the provided
DbBackendConfig configuration. |
DbStateBackend(DbBackendConfig backendConfig,
AbstractStateBackend backend)
Create a new
DbStateBackend using the provided
DbBackendConfig configuration and a different backend for storing
non-partitioned state snapshots. |
DbStateHandle(String jobId,
long checkpointId,
long checkpointTs,
long handleId,
DbBackendConfig dbConfig,
long stateSize) |
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.