The process of OpenScanner in HBase will create two different Scanners to read the data of HFile and MemStore. The Scanner corresponding to HFile is StoreFileScanner, and the Scanner corresponding to MemStore is MemStoreScanner.
As a distributed message system, Kafka supports online and offline message processing, and provides a java API for other components to connect and use. In the Fusioninsight solution, Kafka belongs to the Fusionlnsight HD module.
In Flink, the checkpoint mechanism can ensure that when the application fails during operation, it recovers from a certain checkpoint. During this process, stream snapshots are created sequentially according to the order of data inflow.