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

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

१ अवलोकनम्

1. विन्यासं निष्पादयन्तु

StreamExecutionEnvironment भरतिExecutionConfig, यत् कार्य-विशिष्टविन्यासमूल्यानि रनटाइम् इत्यत्र सेट् कर्तुं अनुमतिं ददाति ।

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
ExecutionConfig executionConfig = env.getConfig();

निम्नलिखितम् उपलभ्यमानाः विन्यासविकल्पाः सन्ति: (पूर्वनिर्धारितरूपेण बोल्ड्)

• setClosureCleanerLevel() . समापनस्वच्छकस्तरः पूर्वनिर्धारितरूपेण सेट् भवतिClosureCleanerLevel.RECURSIVE . क्लोजर क्लीनर् Flink प्रोग्राम् इत्यस्मिन् अनामिकफंक्शन् कॉलिंग् क्लास् इत्यस्य अनावश्यकसन्दर्भान् दूरीकरोति । समापनशुद्धकर्तारं निष्क्रियं कृत्वा, उपयोक्तुः अनामकार्यं कस्यचित् अ-श्रृङ्खलाकरणीयस्य आह्वानवर्गस्य सन्दर्भं ददाति स्यात् । एतेन क्रमाङ्ककः अपवादं क्षिपति । सेट्-करणीयमूल्यानि सन्ति : १.NONE: समापन स्वच्छकं पूर्णतया अक्षमं कुर्वन्तु, .TOP_LEVEL: केवलं क्षेत्रेषु पुनरावृत्तिं विना शीर्षस्तरीयवर्गान् स्वच्छं कुर्वन्तु,RECURSIVE: सर्वाणि क्षेत्राणि पुनरावर्तनीयरूपेण स्वच्छं कुर्वन्तु।
• getParallelism() / setParallelism(int parallelism) . कार्याणां कृते समानान्तरतायाः पूर्वनिर्धारितं डिग्री सेट् करोति ।
• getMaxParallelism() / setMaxParallelism(int parallelism) . कार्याणां कृते पूर्वनिर्धारितं अधिकतमं समानान्तरं सेट् करोति । एषा सेटिङ्ग् समानान्तरतायाः अधिकतमं प्रमाणं निर्धारयति तथा च गतिशीलस्केलिंग् इत्यत्र उपरितनसीमा निर्दिशति ।
• getNumberOfExecutionRetries() / setNumberOfExecutionRetries(int numberOfExecutionRetries) . असफलकार्यस्य पुनः निष्पादनस्य संख्यां सेट् कुर्वन्तु । शून्यस्य मूल्यं प्रभावीरूपेण दोषसहिष्णुतां निष्क्रियं करोति ।-1 सिस्टम् डिफॉल्ट् (विन्यासे परिभाषितम्) इत्यस्य उपयोगं सूचयति ।एतत् विन्यासः अप्रचलितः अस्ति, कृपया तस्य स्थाने पुनः आरम्भरणनीतिं उपयुज्यताम् ।
• getExecutionRetryDelay() / setExecutionRetryDelay(long executionRetryDelay) . विफलतायाः अनन्तरं कार्यं पुनः निष्पादयितुं पूर्वं प्रणाली प्रतीक्षमाणं विलम्बं (मिलिसेकेण्ड्-मात्रायां) सेट् करोति । TaskManagers इत्यत्र सर्वाणि कार्याणि सफलतया स्थगितस्य अनन्तरं विलम्बस्य गणना भवति तथा च एकवारं विलम्बः व्यतीतः चेत् कार्याणि पुनः आरभ्यन्ते ।एतत् विन्यासः अप्रचलितः अस्ति, कृपया तस्य स्थाने पुनः आरम्भरणनीतिं उपयुज्यताम् ।
• getExecutionMode() / setExecutionMode() . पूर्वनिर्धारितः निष्पादनविधिः PIPELINED अस्ति । कार्यक्रमं निष्पादयितुं निष्पादनविधिं सेट् कुर्वन्तु । निष्पादनविधिः परिभाषयति यत् दत्तांशविनिमयः बैच् अथवा स्ट्रीमिंग् मोड् इत्यत्र क्रियते वा इति ।
• enableForceKryo() / disableForceKryo . क्र्यो पूर्वनिर्धारितरूपेण उपयोक्तुं न बाध्यते । GenericTypeInformation इत्यनेन POJOs कृते Kryo serialiser इत्यस्य उपयोगं कर्तुं बाध्यते यद्यपि ते POJOs इत्यस्य रूपेण पार्स् कर्तुं शक्यन्ते । केषुचित् सन्दर्भेषु एतत् विन्यासं सक्षमीकरणं प्राधान्यं भवेत् । यथा, यदा Flink इत्यस्य आन्तरिकः क्रमाङ्ककः POJOs सम्यक् नियन्त्रयितुं असफलः भवति ।
• enableForceAvro() / disableForceAvro() . अवरो पूर्वनिर्धारितरूपेण उपयोक्तुं बाध्यः नास्ति । Avro POJOs क्रमाङ्कनार्थं Kryo इत्यस्य स्थाने Avro serialiser इत्यस्य उपयोगं कर्तुं Flink AvroTypeInfo इत्यस्य बाध्यतां कुर्वन्तु ।
• enableObjectReuse() / disableObjectReuse() . पूर्वनिर्धारितरूपेण Flink मध्ये वस्तुनः पुनः उपयोगः न भवति । वस्तुपुनःप्रयोगविधिं सक्षमीकरणेन रनटाइम् इत्यस्मै उत्तमप्रदर्शनार्थं उपयोक्तृवस्तूनाम् पुनः उपयोगं कर्तुं निर्देशः भवति । एतेन दोषाः भवितुम् अर्हन्ति इति ध्यानं कुर्वन्तु ।
• getGlobalJobParameters() / setGlobalJobParameters() . एषा पद्धतिः उपयोक्तारं कार्यस्य वैश्विकविन्यासे कस्टम् ऑब्जेक्ट् सेट् कर्तुं शक्नोति ।यतःExecutionConfig सर्वेषु उपयोक्तृनिर्धारितकार्येषु सुलभः, अतः कार्येषु वैश्विकरूपेण विन्यासान् उपलब्धं कर्तुं एषः सुलभः उपायः अस्ति ।
• addDefaultKryoSerializer(Class type, Serializer serializer) . निर्दिष्टप्रकारस्य कृते Kryo क्रमाङ्ककदृष्टान्तं पञ्जीकरणं करोति ।
• addDefaultKryoSerializer(Class type, Class
  上一篇 下一篇