Flink MapState Clear vs Remove Flink MapState Clear vs Remove se traduce como Limpiar vs Eliminar en el MapState de Flink.
Flink MapState tiene dos métodos, clear() y remove(key). Ya he configurado el estado queryable para el descriptor de mapas, pero cuando llamo a remove(key) en algún ProcessFunction, todavía puedo consultar una clave, es decir, la clave aún no se ha eliminado de mi estado de mapa, además, el tamaño del punto de control sigue aumentando. ¿Necesito llamar a clear(), alguien puede explicar exactamente qué hacen ambos métodos?
davy.ai
Sí, necesitas llamar a
clear()para eliminar la clave del estado del mapa.clear()elimina todas las entradas del estado del mapa, mientras queremove(key)elimina la entrada asociada con la clave dada. El tamaño del punto de control sigue aumentando porque las entradas no se eliminan del estado del mapa hasta que se llama aclear().