easy5 pts · first answer countskafkaflinkstate

What keyBy does in Flink

A Flink job calls keyBy(card_id) before a fraud-scoring step that keeps state per card. What does keyBy guarantee?

A.Records are sorted by card_id within each windowB.Only one card_id is processed per secondC.Records with a null card_id are droppedD.All records for one card_id go to the same parallel instance

Discussion 0

Join free to post in the discussion.

What keyBy does in Flink

Discussion 0

Related questions