public class RegisteredBroadcastStateBackendMetaInfo<K,V> extends RegisteredStateMetaInfoBase
name
Constructor and Description |
---|
RegisteredBroadcastStateBackendMetaInfo(RegisteredBroadcastStateBackendMetaInfo<K,V> copy) |
RegisteredBroadcastStateBackendMetaInfo(StateMetaInfoSnapshot snapshot) |
RegisteredBroadcastStateBackendMetaInfo(String name,
OperatorStateHandle.Mode assignmentMode,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
Modifier and Type | Method and Description |
---|---|
RegisteredBroadcastStateBackendMetaInfo<K,V> |
deepCopy()
Creates a deep copy of the itself.
|
boolean |
equals(Object obj) |
OperatorStateHandle.Mode |
getAssignmentMode() |
TypeSerializer<K> |
getKeySerializer() |
TypeSerializer<K> |
getPreviousKeySerializer() |
TypeSerializer<V> |
getPreviousValueSerializer() |
TypeSerializer<V> |
getValueSerializer() |
int |
hashCode() |
StateMetaInfoSnapshot |
snapshot() |
String |
toString() |
TypeSerializerSchemaCompatibility<K> |
updateKeySerializer(TypeSerializer<K> newKeySerializer) |
TypeSerializerSchemaCompatibility<V> |
updateValueSerializer(TypeSerializer<V> newValueSerializer) |
fromMetaInfoSnapshot, getName
public RegisteredBroadcastStateBackendMetaInfo(@Nonnull String name, @Nonnull OperatorStateHandle.Mode assignmentMode, @Nonnull TypeSerializer<K> keySerializer, @Nonnull TypeSerializer<V> valueSerializer)
public RegisteredBroadcastStateBackendMetaInfo(@Nonnull RegisteredBroadcastStateBackendMetaInfo<K,V> copy)
public RegisteredBroadcastStateBackendMetaInfo(@Nonnull StateMetaInfoSnapshot snapshot)
@Nonnull public RegisteredBroadcastStateBackendMetaInfo<K,V> deepCopy()
@Nonnull public StateMetaInfoSnapshot snapshot()
snapshot
in class RegisteredStateMetaInfoBase
@Nonnull public TypeSerializer<K> getKeySerializer()
@Nonnull public TypeSerializerSchemaCompatibility<K> updateKeySerializer(TypeSerializer<K> newKeySerializer)
@Nullable public TypeSerializer<K> getPreviousKeySerializer()
@Nonnull public TypeSerializer<V> getValueSerializer()
@Nonnull public TypeSerializerSchemaCompatibility<V> updateValueSerializer(TypeSerializer<V> newValueSerializer)
@Nullable public TypeSerializer<V> getPreviousValueSerializer()
@Nonnull public OperatorStateHandle.Mode getAssignmentMode()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.