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

Post a Comment

Popular posts from this blog

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

-
I do not know how to use mysqli_result like in the past. Is this OK? How is right WHERE status = 'popup' and creditsp> = 1 and (CH) from $ res = mysqli_query ($ con, "SELECT` id`,` usrid`, `url` site Lt; cf || cf = 0) sequence by rand () border 1 "); $ Urll = mysqli_result ($ res, 0, "url"); $ Ownerid = mysqli_result ($ res, 0, "Elixir"); $ Citid = mascile_salt ($ res, 0, "id"); Use fetch_assoc on the results: $ line = $ res-> gt; Fetch_assoc (); $ Urll = $ line ['url']; $ Owner = $ line ['nectar']; $ Site id = $ line ['id']; If there are more than one line, then: while ($ line = $ res-> fetch_assoc ()) {// process $ Line}
Read more

Delphi: missing interface declarations for UI Automation methods -

-
Such a basic question is, but I'm stuck ... I get I'm trying to start with UI Automation using Delphi 2007 (Win32) on Windows 7. It seems that I do not have to use some methods and types. I have the .NET Framework 4.x installed on this machine, but I have imported a type of library from the C: \ Program Files (x86) \ reference assembly \ Microsoft \ Framework \ v3.0 \ UIAutomationClient.dll ... ... I am looking for UIAutomationClient_TLB: UIAutomationClientMajorVersion = 1; UIAutomationClientMinorVersion = 0; I'm not sure that this is the problem (wrong version). I can declare the following with no problem: var UIAuto: IUIAutomation; Element: IUIAutomationElement; But the methods of IUIAutomationElement are missing. For example, there is nothing in the interface declaring this method: IUIAutomationElement.TryGetCurrentPattern () ... which msdn.microsoft According to .com, there is an interface method which is returning to at least NET 3.0. Where do...
Read more

android - How to attach an image from an app to gmail -

-
Text after "div class =" itemprop = "text"> The application to take a picture and attach it to the screen and attach to the second screen, 1 button on the 2nd Gmail Photo on; Send it to someone I am using this code for the second button View public void onClick (v) {// TODO Auto-generated method stub Intent intent = new Intent (Intent. ACTION_SENDTO, Uri.fromParts ("mailto", "test@gmail.com", tap)); Intent.putExtra (Intent.EXTRA_SUBJECT, "test"); Intent.putExtra (Intent.EXTRA_TEXT, "text"); Intent.putExtra (Intent.EXTRA_STREAM, imageUri); StartActivity (Intent.createChooser (meaning, "Choose an Email Client:")); } But this does not attach the photo to Gmail. It may be wrong here is the rest of the code. The public class increases the main activity activity {Private Static Ent TAKE_PICTURE = 1; Private Uri image Yuri; @ Override protected void saved create (bundled Instansstet) {Suprknkret (saved Insten...
Read more