Any concept of a global variable in streams in spring xd? -


परिदृश्य: वसंत xd में एक स्ट्रीम परिभाषा निम्न संरचना है:

jms | फिल्टर | परिणत | Hdfs

फिल्टर मॉड्यूल में, मैं यह सत्यापित करने के लिए एक डेटाबेस को आग्रह करता हूं कि वर्तमान संदेश आगे की प्रक्रिया के लिए लागू है या नहीं।

जब स्थिति पूरी हो जाती है, संदेश ट्रांसमिशन मॉड्यूल।

ट्रांसमीटर मॉड्यूल में, मैं फ़िल्टर मॉड्यूल से क्वेरी परिणामों तक पहुंचना चाहूंगा।

वर्तमान में, मुझे एक बार फिर से एक क्वेरी को आग में डालना होता है एक ही परिणाम सेट तक पहुंचने के लिए ट्रांसफ़ॉर्मेशन के अंदर।

क्या कोई वैश्विक वैरिएबल का कोई भी रूप है, जो अलग-अलग मॉड्यूलों में स्रोत से गुजरने वाले संदेश के जीवनकाल के दौरान आवेदन कर सकता है? इससे डेटाबेस से पढ़ने की विलंब को कम करने में मदद मिल सकती है।

यदि यह संभव नहीं है, तो क्या सुझाए गए विकल्प होंगे?

आप आम तौर पर इसके लिए एक ट्रांसफॉर्मर का उपयोग करेंगे, या शीर्षलेख-एनरिक, क्वेरी परिणाम के साथ एक संदेश हैडर सेट करने के लिए; फ़िल्टर में हैडर का उपयोग करें, और हेडर आपके ट्रांसफॉर्मर सहित डाउनस्ट्रीम मॉड्यूल के लिए उपलब्ध होगा।

  & lt; int: श्रृंखला इनपुट-चैनल = "इनपुट" आउटपुट-चैनल = "आउटपुट" & gt; & LT; int: हेडर-Enricher .... / & gt; & Lt; int: फिल्टर ... / & gt; & Lt; / पूर्णांक: श्रृंखला & gt;   

यह (मनमाना हेडर पारित करना) वर्तमान में केवल खरगोश (और स्थानीय) परिवहन के साथ (बॉक्स के बाहर) काम करता है, या यदि प्रत्यक्ष बाइंडिंग सक्षम है।

जब रेडिस ट्रांसपोर्ट का उपयोग करते हुए, आपको बस अपने पास हैडर को जोड़ने के लिए बस को कॉन्फ़िगर करना होगा।

Comments

Popular posts from this blog

php - how to change mysql_result($res, 0, "url"); to mysqli -

c# - Textbox not clickable but editable -

Matlab transpose a table vector -