Hello, I'm new to Flink. Thank you for your help. My application scenario is to process the log through the Flink program, and finally store the log in HBase.
Through Kafka, my Flink application receives log information from other systems. This information can not be immediately sent to HBASE. I first store these logs into the flink table. After new logs are received, the associated logs will be selected from the link table for calculation. According to the calculation results, they will be stored in HBase or continue to be put into the Flink table. My problem is that when I use SQL statements to query the data structure from the flink table as org.apache.flink.table.api.Table From Flink In the document, the method I learned is to use the org.apache.flink.util.CloseableIterator The iterator of < row > loops through each row to obtain the corresponding field by position. But this is too troublesome. Is there any way to directly convert a Table into my business POJO. In addition, whether there is a way to insert POJO into the link table, I do not seem to see a suitable method. thanks. Json 12.13
