प्रौद्योगिकी साझेदारी

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

फ्लिङ्क् विण्डो ट्रिगर (Trigger) (1) .
फ्लिङ्क् विण्डो ट्रिगर (Trigger) (2) .

अपाचे फ्लिङ्क् असीमित-सीमित-दत्तांश-प्रवाह-संसाधनार्थं मुक्त-स्रोत-धारा-प्रक्रिया-रूपरेखा अस्ति । Flink इत्यस्य time window operation इत्यस्मिन् trigger अतीव महत्त्वपूर्णा अवधारणा अस्ति, या विण्डो इत्यस्य गणना कदा कर्तव्या, परिणामस्य उत्पादनं च निर्धारयति । ट्रिगर्स् कदा विण्डो संसाधितुं सज्जः भवति (अर्थात् यदा गणनाः ट्रिगर भवन्ति) इति शर्ताः परिभाषयन्ति ।
विण्डो प्रकारः

• समयविण्डो(Time Windows): समयविभाजनाधारितं विण्डोज, यथा रोलिंग् टाइम विण्डोज (Tumbling Time Windows) तथा स्लाइडिंग् टाइम विण्डोज (Sliding Time Windows) ।
• घटनासमयविण्डो(Event Time Windows): इवेण्ट् टाइमस्टैम्प्स् इत्यस्य आधारेण विण्डो, यत् क्रमात् बहिः दत्तांशं नियन्त्रयितुं शक्नोति ।

प्रवर्त्यम्

कदा विण्डो गणनायै सज्जः भवति इति शर्ताः परिभाषितुं ट्रिगर्-इत्यस्य उपयोगः भवति । Flink इत्यनेन केचन अन्तःनिर्मितानि ट्रिगर्स् प्रदाति तथा च उपयोक्तृभ्यः आवश्यकतानुसारं ट्रिगर्स् अनुकूलितुं शक्नोति ।

अन्तर्निर्मितः ट्रिगरः

• ProcessingTimeTrigger इति: प्रसंस्करणसमयाधारितः एकः ट्रिगरः यः यदा कदापि निर्दिष्टः समयान्तरः प्राप्यते तदा अग्निम् अयच्छति ।
• EventTimeTrigger इति : इवेण्ट् टाइम् इत्यस्य आधारेण ट्रिगरः, यदा विण्डो इत्यस्य अन्त्यसमयः आगच्छति तदा ट्रिगरः भवति । इदं क्रमबद्धानां अथवा अक्रमितानां घटना-समय-दत्तांश-प्रवाहानाम् संसाधनाय उपयुक्तम् अस्ति ।
• CountTrigger इति: एलिमेण्ट्-सङ्ख्यायाः आधारेण ट्रिगरः, यदा विण्डो-मध्ये एलिमेण्ट्-सङ्ख्या निर्दिष्ट-दहलीजं प्राप्नोति तदा ट्रिगरः भवति ।

कस्टम ट्रिगर

उपयोक्तारः Trigger अन्तरफलकं कार्यान्वितं कृत्वा कस्टम् ट्रिगर्स् निर्मातुम् अर्हन्ति । कस्टम् ट्रिगर्स् जटिलतर्कस्य आधारेण विण्डो गणनाः कदा ट्रिगर कर्तव्याः इति निर्णयं कर्तुं शक्नुवन्ति । कस्टम् ट्रिगर्स् इत्यस्य सामान्यतया निम्नलिखितविधयः कार्यान्वितुं आवश्यकाः भवन्ति ।

• oneElement इति(element, timestamp, window, ctx): यदा विण्डो मध्ये कश्चन तत्वः योजितः भवति तदा आह्वयते ।
• onEventTime इति(time, window, ctx, out): यदा विण्डो इत्यस्य इवेण्ट् टाइम् आगच्छति तदा आह्वयति।
• onProcessingTime इति(time, window, ctx, out): यदा विण्डो इत्यस्य प्रक्रियासमयः आगच्छति तदा आह्वयते ।
• onMerge इति(अन्यम्): यदा द्वौ विण्डो विलीनौ भवतः (उदाहरणार्थं, सत्रविण्डोषु उपयुज्यते) तदा आह्वयते ।
• canMerge इति(): सूचयति यत् ट्रिगरः विण्डो विलयस्य समर्थनं करोति वा इति ।

परिणाम

• ट्रिगरस्य मुख्यं कार्यं विण्डोजस्य गणनासमयं नियन्त्रयितुं भवति, येन Flink इत्यस्य विण्डो-सञ्चालनं अधिकं लचीलं शक्तिशाली च भवति । समीचीन-उद्दीपकाः चयनं कृत्वा, भवान् स्वस्य धारा-प्रक्रियाकरण-अनुप्रयोगानाम् कार्यक्षमतां संसाधन-उपयोगं च अनुकूलितुं शक्नोति ।

उदाहरण

अत्र Flink windows and triggers इत्यस्य उपयोगेन सरलं उदाहरणम् अस्ति (Java API इत्यस्य उपयोगः इति कल्पयित्वा):

DataStream
                                   

                    上一篇
                    下一篇