public void unregisterKvState ( JobID jobId , JobVertexID jobVertexId , KeyGroupRange keyGroupRange , String registrationName , KvStateID kvStateId ) { KvStateEntry < ? , ? , ? > entry = registeredKvStates . remove ( kvStateId ) ; if ( entry != null ) { entry . clear ( ) ; final KvStateRegistryListener listener = getKvStateRegistryListener ( jobId ) ; if ( listener != null ) { listener . notifyKvStateUnregistered ( jobId , jobVertexId , keyGroupRange , registrationName ) ; } } }
Unregisters the KvState instance identified by the given KvStateID .