Hi team,
I'm new to Flink's window and aggregate functions, and I've configured my
state backend as RocksDB. Currently, I'm computing the count of each ID
within a 10-minute duration from the data source. I'm using a HashMap to
aggregate the results. Now, I'm interested in understanding where the data,
particularly the information aggregated within 10 minutes, is stored in the
system for summing each ID. As far as I know, it is stored in RocksDB, but
please correct me if I'm mistaken. I'm particularly confused about how
these local objects, such as HashMap or Hap, are stored in RocksDB, and
what type of data is being stored in RocksDB.

Thanks in Advance,
Arjun S

Reply via email to