在flink 中，如何存储多个k-v并在映射时进行匹配

Question

有userID和cardID。当数据来临时，如果它不能匹配cardID，就存储它，或者检查它的userID。当用户不匹配时，打印一个警告，包括userid和cardID。

我尝试将它们存储在

中

class Bean{
String userID;
String cardID;
}

Liststate<Bean> liststate;

我可以存储它们，只是不知道如何匹配。

Answer 1

您不需要存储k-v。通过cardId键输入流，并在keyedProcessFunction中保留UserId的状态。如果传入的userId与value状态下的userId不相同，则创建警告消息。