मुझे पता है, दो धाराओं के बीच शामिल होने के लिए अभी तक समर्थित नहीं है। लेकिन वैसे भी ऐसा करने का कोई तरीका है? या मुझे स्पार्क 2.2.0 के लिए इंतजार करना होगा? धन्यवादस्पार्क संरचित स्ट्रीमिंग पर मैं दो धाराओं के बीच कैसे जुड़ूं? - जावा 8
उत्तर
स्पार्क 2.2.0 अभी भी स्ट्रीम-स्ट्रीम में शामिल होने का समर्थन नहीं करेगा। आप इस टिकट देख सकते हैं: https://issues.apache.org/jira/browse/SPARK-18791
क्या यह 2.3 में उपलब्ध होगा? – user1870400
हां। 2.3 इसका समर्थन करेगा। – zsxwing
हाय! मैं सिर्फ स्पार्क 2.3 आरसी 4 स्ट्रीम-स्ट्रीम में शामिल था। किसी भी तरह से मैं स्ट्रीमिंग डेटाफ्रेम पर आसानी से शामिल नहीं हो सका। और मुझे यकीन नहीं है कि क्यों .. यह मेरा वाक्यविन्यास हो सकता है लेकिन मुझे यकीन नहीं है .. अधिक जानकारी यहां https://stackoverflow.com/questions/48900127/how-to-do-a-self-join-in-spark -2-3-0-क्या-सही-वाक्य-वाक्य अच्छा होगा यदि आप इस पर मदद कर सकते हैं !! – user1870400
मैं तुम्हें काफ्का स्ट्रीम के बजाय संरचित स्पार्क स्ट्रीमिंग का उपयोग कर यदि आप धाराओं में शामिल करना चाहते सलाह देते हैं .. check this link to see how this can be done
धन्यवाद, लेकिन मैंने पहले ही कफका स्ट्रीम का उपयोग किया है। मैं विशिष्ट कारणों से कुछ अलग स्ट्रीमिंग इंजनों को आजमाने की कोशिश करता हूं: डी –
स्पार्क 2.3 के उत्पादन रिलीज़ है, इसलिए stream-stream joins अब संरचित स्ट्रीमिंग में समर्थित हैं ।
- 1. स्पार्क संरचित स्ट्रीमिंग
- 2. स्पार्क संरचित स्ट्रीमिंग: एकाधिक सिंक
- 3. अपाचे स्पार्क (स्ट्रीमिंग संरचित): S3 चेकप्वाइंट समर्थन
- 4. कैसे स्पार्क में कई बैच के अंतराल पर डेटा धाराओं
- 5. मैं पाइप पर कैसे जुड़ूं?
- 6. स्पार्क-स्ट्रीमिंग
- 7. मैं स्पार्क स्ट्रीमिंग नौकरी कैसे रोकूं?
- 8. स्पार्क स्ट्रीमिंग
- 9. स्पार्क स्ट्रीमिंग
- 10. काफ्का स्ट्रीमिंग + स्पार्क स्ट्रीमिंग + मशीन लर्निंग
- 11. जावा 8 संग्रह स्ट्रीमिंग एपीआई
- 12. एक अभिनेता से स्पार्क-स्ट्रीमिंग
- 13. स्पार्क स्ट्रीमिंग 1.6.0 -
- 14. स्पार्क स्ट्रीमिंग डेटा को स्पार्क डेटाफ्रेम
- 15. स्पार्क स्ट्रीमिंग UpdateStateByKey
- 16. कैसे दो या अधिक धाराओं
- 17. स्पार्क स्ट्रीमिंग फ़ाइलस्ट्रीम
- 18. मैं कैसे जावा 8 धारा
- 19. धाराओं का उपयोग करके इसे कैसे लिखें? जावा 8
- 20. स्पार्क स्ट्रीमिंग काफ्का स्ट्रीम
- 21. kafka कनेक्ट 0.10 और स्पार्क संरचित स्ट्रीमिंग से_json का उपयोग कैसे करें?
- 22. अपाचे स्पार्क स्ट्रीमिंग
- 23. अपाचे स्पार्क स्ट्रीमिंग
- 24. अपाचे स्पार्क स्ट्रीमिंग
- 25. जावा 8 धाराओं के साथ एक सूची का रिफैक्टर निर्माण
- 26. जावा 8 - धारा, नक्शा और जावा 8 धाराओं के साथ अलग
- 27. नेट धाराओं, वस्तुओं के बीच धाराओं गुजर, सर्वोत्तम प्रथाओं (सी #)
- 28. स्ट्रीमिंग और लाइव स्ट्रीमिंग के बीच अंतर?
- 29. मैं रिलेटिवसोर्स सेल्फ से कैसे जुड़ूं?
- 30. स्पार्क उदाहरण स्ट्रीमिंग अतिरिक्त पैरामीटर
क्या आपको संरचित स्ट्रीमिंग के साथ ऐसा करने का कोई तरीका मिला? – vkr