Package org.apache.flink.state.forst

Class ForStValueState<K,V>

java.lang.Object

org.apache.flink.runtime.state.v2.InternalKeyedState<K,V>

org.apache.flink.runtime.state.v2.InternalValueState<K,V>

org.apache.flink.state.forst.ForStValueState<K,V>

Type Parameters:

K - The type of the key.

V - The type of the value.

All Implemented Interfaces:

org.apache.flink.api.common.state.v2.State, org.apache.flink.api.common.state.v2.ValueState<V>, ForStInnerTable<ContextKey<K>,V>

public class ForStValueState<K,V>
extends org.apache.flink.runtime.state.v2.InternalValueState<K,V>
implements org.apache.flink.api.common.state.v2.ValueState<V>, ForStInnerTable<ContextKey<K>,V>

The InternalValueState implement for ForStDB.

Constructor Summary

Constructors

Constructor

Description

ForStValueState(org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateRequestHandler, org.rocksdb.ColumnFamilyHandle columnFamily, org.apache.flink.runtime.state.v2.ValueStateDescriptor<V> valueStateDescriptor, java.util.function.Supplier<org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K>> serializedKeyBuilderInitializer, java.util.function.Supplier<org.apache.flink.core.memory.DataOutputSerializer> valueSerializerViewInitializer, java.util.function.Supplier<org.apache.flink.core.memory.DataInputDeserializer> valueDeserializerViewInitializer)

Method Summary

Modifier and Type	Method	Description
ForStDBGetRequest<ContextKey<K>,V>	buildDBGetRequest(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?> stateRequest)	Build a ForStDBGetRequest that belong to this ForStInnerTable with the given stateRequest.
ForStDBPutRequest<ContextKey<K>,V>	buildDBPutRequest(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?> stateRequest)	Build a ForStDBPutRequest that belong to ForStInnerTable with the given stateRequest.
V	deserializeValue(byte[] valueBytes)	Deserialize the given bytes value to POJO value.
org.rocksdb.ColumnFamilyHandle	getColumnFamilyHandle()	Get the columnFamily handle corresponding to table.
byte[]	serializeKey(ContextKey<K> contextKey)	Serialize the given key to bytes.
byte[]	serializeValue(V value)	Serialize the given value to the outputView.

Methods inherited from class org.apache.flink.runtime.state.v2.InternalValueState

asyncUpdate, asyncValue

Methods inherited from class org.apache.flink.runtime.state.v2.InternalKeyedState

asyncClear, getStateDescriptor, getValueSerializer, handleRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.common.state.v2.State

asyncClear

Methods inherited from interface org.apache.flink.api.common.state.v2.ValueState

asyncUpdate, asyncValue

Constructor Detail

ForStValueState

public ForStValueState(org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateRequestHandler,
                       org.rocksdb.ColumnFamilyHandle columnFamily,
                       org.apache.flink.runtime.state.v2.ValueStateDescriptor<V> valueStateDescriptor,
                       java.util.function.Supplier<org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K>> serializedKeyBuilderInitializer,
                       java.util.function.Supplier<org.apache.flink.core.memory.DataOutputSerializer> valueSerializerViewInitializer,
                       java.util.function.Supplier<org.apache.flink.core.memory.DataInputDeserializer> valueDeserializerViewInitializer)

Method Detail

getColumnFamilyHandle

public org.rocksdb.ColumnFamilyHandle getColumnFamilyHandle()

Description copied from interface: ForStInnerTable

Get the columnFamily handle corresponding to table.

Specified by:

getColumnFamilyHandle in interface ForStInnerTable<K,V>

serializeKey

public byte[] serializeKey(ContextKey<K> contextKey)
                    throws IOException

Description copied from interface: ForStInnerTable

Serialize the given key to bytes.

Specified by:

serializeKey in interface ForStInnerTable<K,V>

Parameters:

contextKey - the key to be serialized.

Returns:

the key bytes

Throws:

IOException - Thrown if the serialization encountered an I/O related error.

serializeValue

public byte[] serializeValue(V value)
                      throws IOException

Description copied from interface: ForStInnerTable

Serialize the given value to the outputView.

Specified by:

serializeValue in interface ForStInnerTable<K,V>

Parameters:

value - the value to be serialized.

Returns:

the value bytes

Throws:

IOException - Thrown if the serialization encountered an I/O related error.

deserializeValue

public V deserializeValue(byte[] valueBytes)
                   throws IOException

Description copied from interface: ForStInnerTable

Deserialize the given bytes value to POJO value.

Specified by:

deserializeValue in interface ForStInnerTable<K,V>

Parameters:

valueBytes - the value bytes to be deserialized.

Returns:

the deserialized POJO value

Throws:

IOException - Thrown if the deserialization encountered an I/O related error.

buildDBGetRequest

public ForStDBGetRequest<ContextKey<K>,V> buildDBGetRequest(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?> stateRequest)

Description copied from interface: ForStInnerTable

Build a ForStDBGetRequest that belong to this ForStInnerTable with the given stateRequest.

Specified by:

buildDBGetRequest in interface ForStInnerTable<K,V>

Parameters:

stateRequest - The given stateRequest.

Returns:

The corresponding ForSt GetRequest.

buildDBPutRequest

public ForStDBPutRequest<ContextKey<K>,V> buildDBPutRequest(org.apache.flink.runtime.asyncprocessing.StateRequest<?,?,?> stateRequest)

Description copied from interface: ForStInnerTable

Build a ForStDBPutRequest that belong to ForStInnerTable with the given stateRequest.

Specified by:

buildDBPutRequest in interface ForStInnerTable<K,V>

Parameters:

stateRequest - The given stateRequest.

Returns:

The corresponding ForSt PutRequest.