org.apache.flink.contrib.streaming.state

Class RocksDBAggregatingState<K,N,T,ACC,R>

java.lang.Object

org.apache.flink.contrib.streaming.state.AbstractRocksDBState<K,N,org.apache.flink.api.common.state.AggregatingState<T,R>,org.apache.flink.api.common.state.AggregatingStateDescriptor<T,ACC,R>,ACC>

org.apache.flink.contrib.streaming.state.RocksDBAggregatingState<K,N,T,ACC,R>

Type Parameters:

K - The type of the key

N - The type of the namespace

T - The type of the values that aggregated into the state

ACC - The type of the value stored in the state (the accumulator type)

R - The type of the value returned from the state

All Implemented Interfaces:

org.apache.flink.api.common.state.AggregatingState<T,R>, org.apache.flink.api.common.state.AppendingState<T,R>, org.apache.flink.api.common.state.MergingState<T,R>, org.apache.flink.api.common.state.State, org.apache.flink.runtime.state.internal.InternalAggregatingState<N,T,R>, org.apache.flink.runtime.state.internal.InternalAppendingState<N,T,R>, org.apache.flink.runtime.state.internal.InternalKvState<N>, org.apache.flink.runtime.state.internal.InternalMergingState<N,T,R>

public class RocksDBAggregatingState<K,N,T,ACC,R>
extends AbstractRocksDBState<K,N,org.apache.flink.api.common.state.AggregatingState<T,R>,org.apache.flink.api.common.state.AggregatingStateDescriptor<T,ACC,R>,ACC>
implements org.apache.flink.runtime.state.internal.InternalAggregatingState<N,T,R>

An AggregatingState implementation that stores state in RocksDB.

Field Summary

Fields inherited from class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

backend, columnFamily, keySerializationDataOutputView, keySerializationStream, stateDesc

Constructor Summary

Constructors

Constructor and Description
RocksDBAggregatingState(org.rocksdb.ColumnFamilyHandle columnFamily, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.AggregatingStateDescriptor<T,ACC,R> stateDesc, RocksDBKeyedStateBackend<K> backend) Creates a new RocksDBFoldingState.

Method Summary

Modifier and Type	Method and Description
void	add(T value)
R	get()
void	mergeNamespaces(N target, Collection<N> sources)

Methods inherited from class org.apache.flink.contrib.streaming.state.AbstractRocksDBState

clear, getSerializedValue, readKeyWithGroupAndNamespace, setCurrentNamespace, writeCurrentKeyWithGroupAndNamespace, writeKeyWithGroupAndNamespace

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.runtime.state.internal.InternalKvState

getSerializedValue, setCurrentNamespace

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

clear

Constructor Detail

RocksDBAggregatingState

public RocksDBAggregatingState(org.rocksdb.ColumnFamilyHandle columnFamily,
                               org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
                               org.apache.flink.api.common.state.AggregatingStateDescriptor<T,ACC,R> stateDesc,
                               RocksDBKeyedStateBackend<K> backend)

Creates a new RocksDBFoldingState.

Parameters:

namespaceSerializer - The serializer for the namespace.

stateDesc - The state identifier for the state. This contains the state name and aggregation function.

Method Detail

get

public R get()
      throws IOException

Specified by:

get in interface org.apache.flink.api.common.state.AppendingState<T,R>

Throws:

IOException

add

public void add(T value)
         throws IOException

Specified by:

add in interface org.apache.flink.api.common.state.AppendingState<T,R>

Throws:

IOException

mergeNamespaces

public void mergeNamespaces(N target,
                            Collection<N> sources)
                     throws Exception

Specified by:

mergeNamespaces in interface org.apache.flink.runtime.state.internal.InternalMergingState<N,T,R>

Throws:

Exception