Flink 1.11 DataStream API पेज पर, वहां एक WindowWordCount प्रोग्राम है जो keyBy () का उपयोग करता है, हालांकि, इस विधि को हटा दिया गया है, मुझे कोई उदाहरण नहीं मिला कि keyBy का उपयोग किए बिना इसे फिर से कैसे लिखा जाए। ()। किसी भी सुझाव की बहुत सराहना की जाएगी।
मैं इंटेलिज का उपयोग करता हूं; यह चेतावनी देता है keyBy() पदावनत है। यह एकमात्र लिंक है जो मुझे मिल सका।
1 उत्तर
एक पूर्णांक या स्ट्रिंग पैरामीटर लेने वाले keyBy के रूपों को बहिष्कृत कर दिया गया है। आपको keyBy के रूप का उपयोग करना चाहिए जो एक KeySelector फ़ंक्शन लेता है - उदाहरण के लिए, प्रतिस्थापित करें
stream.keyBy("id")
साथ
stream.keyBy(event -> event.id)
और बदलें
streamOfTuples.keyBy(0)
साथ
streamOfTuples(tuple -> tuple.f0)
संबंधित सवाल
नए सवाल
apache-flink
Apache Flink स्केलेबल बैच और स्ट्रीम डेटा प्रोसेसिंग के लिए एक ओपन सोर्स प्लेटफॉर्म है। फ्लिंक एक सिस्टम में बैच और स्ट्रीमिंग एनालिटिक्स का समर्थन करता है। विश्लेषणात्मक कार्यक्रमों को जावा और स्काला में संक्षिप्त और सुरुचिपूर्ण एपीआई में लिखा जा सकता है।