StateManagerImplV2 is a concrete StateManager (as a StateManagerImplBase) that is used by default in FlatMapGroupsWithStateExec physical operator (per spark.sql.streaming.flatMapGroupsWithState.stateFormatVersion internal configuration property).
StateManagerImplV2 takes the following to be created:
- [[stateEncoder]] State encoder (
StateManagerImplV2 is created when:
FlatMapGroupsWithStateExecHelperutility is requested for a StateManager (when the