Package org.apache.flink.runtime.state

Interface BackendWritableBroadcastState<K,V>

Type Parameters:

K - The key type of the elements in the Broadcast State.

V - The value type of the elements in the Broadcast State.

All Superinterfaces:

BroadcastState<K,V>, ReadOnlyBroadcastState<K,V>, State

All Known Implementing Classes:

HeapBroadcastState

public interface BackendWritableBroadcastState<K,V>
extends BroadcastState<K,V>

An interface with methods related to the interplay between the Broadcast State and the OperatorStateBackend.

Method Summary

Modifier and Type	Method	Description
BackendWritableBroadcastState<K,V>	deepCopy()
RegisteredBroadcastStateBackendMetaInfo<K,V>	getStateMetaInfo()
void	setStateMetaInfo(RegisteredBroadcastStateBackendMetaInfo<K,V> stateMetaInfo)
long	write(FSDataOutputStream out)

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

entries, iterator, put, putAll, remove

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

contains, get, immutableEntries

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

clear

Method Detail

deepCopy

BackendWritableBroadcastState<K,V> deepCopy()

write

long write(FSDataOutputStream out)
    throws IOException

Throws:

IOException

setStateMetaInfo

void setStateMetaInfo(RegisteredBroadcastStateBackendMetaInfo<K,V> stateMetaInfo)

getStateMetaInfo

RegisteredBroadcastStateBackendMetaInfo<K,V> getStateMetaInfo()