Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202552705
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredBroadcastStateBackendMetaInfo.java
---
@@ -24,37 +24,46 @@
import org.apache.flink.util.Preconditions;
import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
-public class RegisteredBroadcastBackendStateMetaInfo<K, V> extends
RegisteredStateMetaInfoBase {
+public class RegisteredBroadcastStateBackendMetaInfo<K, V> extends
RegisteredStateMetaInfoBase {
/** The mode how elements in this state are assigned to tasks during
restore. */
+ @Nonnull
private final OperatorStateHandle.Mode assignmentMode;
/** The type serializer for the keys in the map state. */
+ @Nonnull
private final TypeSerializer<K> keySerializer;
/** The type serializer for the values in the map state. */
+ @Nonnull
private final TypeSerializer<V> valueSerializer;
- public RegisteredBroadcastBackendStateMetaInfo(
- final String name,
- final OperatorStateHandle.Mode assignmentMode,
- final TypeSerializer<K> keySerializer,
- final TypeSerializer<V> valueSerializer) {
+ /** The precomputed immutable snapshot of this state */
+ @Nullable
+ private StateMetaInfoSnapshot precomputedSnapshot;
--- End diff --
nit: Maybe rename to `precomputedStateMetaInfoSnapshot`
---
