Flink 1.11 DataStream API पेज पर, वहां एक WindowWordCount प्रोग्राम है जो keyBy () का उपयोग करता है, हालांकि, इस विधि को हटा दिया गया है, मुझे कोई उदाहरण नहीं मिला कि keyBy का उपयोग किए बिना इसे फिर से कैसे लिखा जाए। ()। किसी भी सुझाव की बहुत सराहना की जाएगी।

मैं इंटेलिज का उपयोग करता हूं; यह चेतावनी देता है keyBy() पदावनत है। यह एकमात्र लिंक है जो मुझे मिल सका।

2
user342673 2 अगस्त 2020, 19:05

1 उत्तर

सबसे बढ़िया उत्तर

एक पूर्णांक या स्ट्रिंग पैरामीटर लेने वाले keyBy के रूपों को बहिष्कृत कर दिया गया है। आपको keyBy के रूप का उपयोग करना चाहिए जो एक KeySelector फ़ंक्शन लेता है - उदाहरण के लिए, प्रतिस्थापित करें

stream.keyBy("id")

साथ

stream.keyBy(event -> event.id)

और बदलें

streamOfTuples.keyBy(0)

साथ

streamOfTuples(tuple -> tuple.f0)
3
David Anderson 2 अगस्त 2020, 21:50