मैं एक कैसंड्रा टेबल से डेटा स्ट्रीम करना चाहता हूं जो वास्तविक समय में अपडेट किया गया है। हां, यह एक डेटाबेस है लेकिन क्या ऐसा करने का कोई तरीका है? यदि ऐसा है, तो ऑफसेट रखना या सीक्यूएल प्रश्न क्या मैं उपयोग कर सकता हूं?कैसंड्रा तालिका से डेटा को स्ट्रीम कैसे करें?
संक्षिप्त उत्तर नहीं है।
लंबा उत्तर बहुत कठिनाई और स्मार्ट क्लस्टरिंग कुंजियों के साथ है जो आप शायद ऐसा कर सकते हैं। असल में यदि आप एक क्लस्टरिंग कुंजी के साथ डेटा डालते हैं जो हमेशा बढ़ता है तो आप हमेशा हाल के समय के अंतराल में क्लस्टरिंग कुंजियों के लिए स्कैन कर सकते हैं। यह निश्चित रूप से आपकी खिड़की के बाहर आउट-ऑफ-ऑर्डर प्रविष्टियों को याद करेगा। यह आपके उपयोग के मामले के लिए पर्याप्त हो सकता है या नहीं भी हो सकता है।
भविष्य मेंबेस्ट जवाब है बदलें डाटा कैप्चर: https://issues.apache.org/jira/browse/CASSANDRA-8844
शायद ट्रिगर भी हो सकता है? –
@RussS लिंक के लिए धन्यवाद अच्छी जानकारी –
क्या किसी के पास इस बारे में कुछ विचार है कि इस में स्पार्क-कैसंड्रा-कनेक्टर का उपयोग कैसे किया जा सकता है? क्या यह ऑफसेट की देखभाल करता है और क्या यह डेटा को वास्तविक समय में स्ट्रीम करता है? –
किसी को भी कैसे चिंगारी कैसेंड्रा-कनेक्टर इस में इस्तेमाल किया जा सकता पर कुछ विचार है? क्या यह ऑफसेट की देखभाल करता है और क्या यह डेटा को वास्तविक समय में स्ट्रीम करता है? –