संदर्भ: मैं लॉग से विभिन्न घटना प्रकारों की चलती गणना को बढ़ाने के लिए अपाचे स्पार्क का उपयोग कर रहा हूं, मैं बैच आरडीडी से परिणाम जोड़ता हूं। ऐतिहासिक विश्लेषण उद्देश्यों और रीयलटाइम विश्लेषण उद्देश्
में पार्सिंग जेसन मैं स्पार्क के लिए बहुत नया हूं और मैं एक कफका विषय से जेसन के रूप में संरचित डीस्ट्रीम प्राप्त करने की कोशिश कर रहा हूं और मैं प्रत्येक जेसन की सामग्री को पार्स करना चाहता हूं। {"ty
यह स्कैला में लिखा गया एक स्पार्क स्ट्रीमिंग प्रोग्राम है। यह प्रत्येक 1 सेकंड में सॉकेट से शब्दों की संख्या की गणना करता है। नतीजा शब्द गणना होगी, उदाहरण के लिए, शब्द 0 से 1 तक गिनती है, और शब्द 1 से