मौजूदा समूहों का एक पृष्ठ लौटाता है
सवाल पैरामीटर
| समूहराज्य | की सरणी तार (समूहराज्य) आइटम एनम: "सक्रिय" "संग्रहीत" फ़िल्टरिंग के लिए आवेदन करने के लिए समूह राज्यों की सूची |
| समूहप्रकार | की सरणी तार (ग्रुपकाइंड) आइटम एनम: "नौकरी" "कोड" फ़िल्टरिंग के लिए लागू करने के लिए समूह प्रकारों की सूची |
| नौकरी राज्य | की सरणी तार (नौकरीराज्य) चूक: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" आइटम एनम: "सबमिट किया गया" "शुरू" "तैयार" "व्यस्त" "विफल" "समाप्त" "CANCELED" "अज्ञात" फ़िल्टरिंग के लिए आवेदन करने के लिए नौकरी राज्यों की सूची |
| क्लस्टरनाम | की सरणी तार फ़िल्टरिंग के लिए लागू करने के लिए क्लस्टर नामों की सूची |
| टैग | तार फ़िल्टरिंग के लिए आवेदन करने के लिए टैग की एक अर्धविराम अलग सूची। पैटर्न: कुंजी 1 = मान 1; कुंजी2=मान2 |
| ढूँढ | तार फ़िल्टरिंग के लिए लागू करने के लिए शब्द |
| पृष्ठ | पूर्ण संख्या चूक: 0 लौटाए जाने वाले पृष्ठ की संख्या |
| आकार वाला | पूर्ण संख्या चूक: 10 लौटाए जाने वाले पृष्ठ का आकार |
| जाति | की सरणी तार उदाहरण: क्रमबद्ध करें = नाम में, ASC पेजिंग क्रम परिभाषित करने के लिए लागू किए जाने वाले सॉर्ट नियम |
जवाब
प्रतिक्रिया के नमूने
- 200
{- "पृष्ठ": {
- "संख्या": 0,
- "आकार": 0,
- "ऑफसेट": 0,
- "पृष्ठांकित": सच्चा
}, - "क्रमबद्ध": [
- "स्ट्रिंग"
], - "टोटल एलिमेंट्स": 0,
- "कुल पृष्ठ": 0,
- "पहले": सच्चा,
- "अंतिम": सच्चा,
- "खाली": सच्चा,
- "सामग्री": [
- {
- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "दयालु": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "पैमाना": 0,
- "jobConfig": { },
- "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "बनाया गया समय": 0,
- "संग्रहीत समय": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "autoPause": सच्चा,
- "नौकरियां": [
- {
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}
]
}इंटरैक्टिव स्पार्क नौकरियों का एक समूह बनाता है
अनुरोध बॉडी स्कीमा: मल्टीपार्ट/फॉर्म-डेटाआवश्यक
| नाम आवश्यक | तार |
| या क़िस्म | तार |
| प्रकार | तार चूक: "नौकरी" एनम: "नौकरी" "कोड" |
| टैग | तार चूक: "कुंजी = मूल्य; कुंजी2=मान2" टैग की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| भाषा | तार चूक: "स्केल" एनम: "स्केल" "पायथन" |
| क्लस्टरनाम आवश्यक | तार चूक: "डिफ़ॉल्ट" |
| जार | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| फ़ाइलें | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| pyFiles | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| jobConfig | तार चूक: "spark.key = मान; स्पार्क.की2=मान2" स्पार्क नौकरी के लिए लागू किए जाने वाले स्पार्क मापदंडों की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| pyआवश्यकताएँ | तार अजगर आवश्यकताओं की एक अर्धविराम अलग सूची। पैकेज नाम और संस्करण (यदि दिया गया है) को डबल बराबर चिह्न द्वारा अलग किया जाना चाहिए। |
| packages | तार Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version. |
| पैमाना | तार चूक: 1 इस समूह के भीतर लॉन्च की जाने वाली स्पार्क नौकरियों की पूर्णांक गणना |
| executors | तार number of executors to run |
| driverCores | तार Number of cores to use for the driver process. |
| executorCores | तार The number of cores to use on each executor. |
| driverMemory | तार Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| executorMemory | तार Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| dynamicAllocation | तार चूक: "झूठा" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload. |
| initialExecutors | तार Initial number of executors to run if dynamic allocation is enabled. |
| minExecutors | तार Upper bound for the number of executors if dynamic allocation is enabled. |
| maxExecutors | तार Lower bound for the number of executors if dynamic allocation is enabled. |
| autoPause | तार चूक: "झूठा" Boolean flag to enable auto-pause feature |
जवाब
प्रतिक्रिया के नमूने
- 200
- 402
- 404
- 409
{- "समूहआईडी": "स्ट्रिंग"
}उसकी id द्वारा पाया गया समूह लौटाता है
पथ पैरामीटर
| समूह आईडी आवश्यक | तार किसी समूह का युनीक आइडेंटिफ़ायर |
जवाब
प्रतिक्रिया के नमूने
- 200
- 404
{- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "दयालु": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "पैमाना": 0,
- "jobConfig": { },
- "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "बनाया गया समय": 0,
- "संग्रहीत समय": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "autoPause": सच्चा,
- "नौकरियां": [
- {
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}Updates a group by its id
पथ पैरामीटर
| समूह आईडी आवश्यक | तार किसी समूह का युनीक आइडेंटिफ़ायर |
अनुरोध बॉडी स्कीमा: मल्टीपार्ट/फॉर्म-डेटाआवश्यक
| या क़िस्म | तार |
| टैग | तार टैग की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| jobConfig | तार स्पार्क नौकरी के लिए लागू किए जाने वाले स्पार्क मापदंडों की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| pyआवश्यकताएँ | तार अजगर आवश्यकताओं की एक अर्धविराम अलग सूची। पैकेज नाम और संस्करण (यदि दिया गया है) को डबल बराबर चिह्न द्वारा अलग किया जाना चाहिए। |
| packages | तार Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version. |
| पैमाना | तार इस समूह के भीतर लॉन्च की जाने वाली स्पार्क नौकरियों की पूर्णांक गणना |
| executors | तार number of executors to run |
| driverCores | तार Number of cores to use for the driver process. |
| executorCores | तार The number of cores to use on each executor. |
| driverMemory | तार Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| executorMemory | तार Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| dynamicAllocation | तार चूक: "झूठा" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload. |
| initialExecutors | तार Initial number of executors to run if dynamic allocation is enabled. |
| minExecutors | तार Upper bound for the number of executors if dynamic allocation is enabled. |
| maxExecutors | तार Lower bound for the number of executors if dynamic allocation is enabled. |
| autoPause | तार चूक: "झूठा" Boolean flag to enable auto-pause feature |
जवाब
प्रतिक्रिया के नमूने
- 402
- 404
- 409
{- "संदेश": "स्ट्रिंग"
}चुने हुए समूह के भीतर एक इंटरैक्टिव स्पार्क कार्य निष्पादित करता है
चुने हुए समूह के भीतर एक इंटरैक्टिव स्पार्क नौकरी निष्पादित करता है और नौकरी के उदाहरण के पूरा होने की प्रतीक्षा करता है। इसका परिणाम प्रतिक्रिया के रूप में लौटाया जाता है।
पथ पैरामीटर
| समूह आईडी आवश्यक | तार किसी समूह का युनीक आइडेंटिफ़ायर |
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| प्रकार आवश्यक | तार चूक: "interactive_job_execute" |
| jobClass आवश्यक | तार |
आवश्यक | वस्तु |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "प्रकार": "interactive_job_execute",
- "नौकरी वर्ग": "स्ट्रिंग",
- "jobConfig": { }
}प्रतिक्रिया के नमूने
- 200
- 402
- 404
- 409
{- "jobInstanceId": "स्ट्रिंग",
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "नौकरी वर्ग": "स्ट्रिंग",
- "jobConfig": { },
- "परिणाम": "स्ट्रिंग",
- "त्रुटि": {
- "संदेश": "स्ट्रिंग",
- "स्टैकट्रेस": "स्ट्रिंग"
}
}मौजूदा समूह कार्य आवृत्ति परिणामों का एक पृष्ठ लौटाता है
पथ पैरामीटर
| समूह आईडी आवश्यक | तार किसी समूह का युनीक आइडेंटिफ़ायर |
सवाल पैरामीटर
| ढूँढ | तार फ़िल्टरिंग के लिए लागू करने के लिए शब्द |
| पृष्ठ | पूर्ण संख्या चूक: 0 लौटाए जाने वाले पृष्ठ की संख्या |
| आकार वाला | पूर्ण संख्या चूक: 10 लौटाए जाने वाले पृष्ठ का आकार |
| जाति | की सरणी तार उदाहरण: क्रमबद्ध करें = नाम में, ASC पेजिंग क्रम परिभाषित करने के लिए लागू किए जाने वाले सॉर्ट नियम |
जवाब
प्रतिक्रिया के नमूने
- 200
{- "पृष्ठ": {
- "संख्या": 0,
- "आकार": 0,
- "ऑफसेट": 0,
- "पृष्ठांकित": सच्चा
}, - "क्रमबद्ध": [
- "स्ट्रिंग"
], - "टोटल एलिमेंट्स": 0,
- "कुल पृष्ठ": 0,
- "पहले": सच्चा,
- "अंतिम": सच्चा,
- "खाली": सच्चा,
- "सामग्री": [
- {
- "jobInstanceId": "स्ट्रिंग",
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "नौकरी वर्ग": "स्ट्रिंग",
- "jobConfig": { },
- "परिणाम": "स्ट्रिंग",
- "त्रुटि": {
- "संदेश": "स्ट्रिंग",
- "स्टैकट्रेस": "स्ट्रिंग"
}
}
]
}चुने हुए समूह के भीतर एक इंटरैक्टिव स्पार्क नौकरी सबमिट करता है
चुने हुए समूह के भीतर एक इंटरैक्टिव स्पार्क नौकरी सबमिट करता है। यह काम पूरा होने की प्रतीक्षा नहीं करता है। इसके बजाय यह बनाई गई नौकरी इंस्टेंस आईडी लौटाता है। इसका परिणाम नौकरी के उदाहरण परिणाम द्वारा प्राप्त किया जा सकता है सदस्यता अपडेट करें।
पथ पैरामीटर
| समूह आईडी आवश्यक | तार किसी समूह का युनीक आइडेंटिफ़ायर |
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| प्रकार आवश्यक | तार चूक: "interactive_job_execute" |
| jobClass आवश्यक | तार |
आवश्यक | वस्तु |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "प्रकार": "interactive_job_execute",
- "नौकरी वर्ग": "स्ट्रिंग",
- "jobConfig": { }
}प्रतिक्रिया के नमूने
- 200
- 402
- 404
- 409
{- "jobInstanceId": "स्ट्रिंग"
}चयनित समूह द्वारा उपयोग किए जाने वाले इंटरैक्टिव स्पार्क कार्यों की संख्या बदलता है
पथ पैरामीटर
| समूह आईडी आवश्यक | तार किसी समूह का युनीक आइडेंटिफ़ायर |
| पैमाना आवश्यक | पूर्ण संख्या समूह के भीतर इंटरैक्टिव स्पार्क नौकरी को स्केल करने के लिए उदाहरणों की संख्या |
जवाब
प्रतिक्रिया के नमूने
- 402
- 404
{- "संदेश": "स्ट्रिंग"
}इंटरैक्टिव स्पार्क नौकरी परिणाम परिवर्तनों की एक धारा देता है
सवाल पैरामीटर
| जॉब आईडी | की सरणी तार फ़िल्टरिंग के लिए आवेदन करने के लिए नौकरी आईडी की सूची |
| ग्रुपआईडी | की सरणी तार फ़िल्टरिंग के लिए आवेदन करने के लिए समूह आईडी की सूची |
| क्लस्टरनाम | की सरणी तार फ़िल्टरिंग के लिए लागू करने के लिए क्लस्टर नामों की सूची |
| समूह नाम | की सरणी तार फ़िल्टरिंग के लिए आवेदन करने के लिए समूह नामों की सूची |
| टैग | तार फ़िल्टरिंग के लिए आवेदन करने के लिए टैग की एक अर्धविराम अलग सूची। पैटर्न: कुंजी 1 = मान 1; कुंजी2=मान2 |
जवाब
प्रतिक्रिया के नमूने
- 200
- 404
{- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "दयालु": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "पैमाना": 0,
- "jobConfig": { },
- "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "बनाया गया समय": 0,
- "संग्रहीत समय": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "autoPause": सच्चा,
- "नौकरियां": [
- {
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}Returns a page of existing schedules
सवाल पैरामीटर
| scheduleStates | की सरणी तार (scheduleState) चूक: "ENABLED" आइटम एनम: "ENABLED" "DISABLED" "PAUSED" The list of schedule states to apply for filtering |
| scheduleCrons | की सरणी तार The list of schedule crons to apply for filtering |
| नौकरी राज्य | की सरणी तार (नौकरीराज्य) चूक: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" आइटम एनम: "सबमिट किया गया" "शुरू" "तैयार" "व्यस्त" "विफल" "समाप्त" "CANCELED" "अज्ञात" फ़िल्टरिंग के लिए आवेदन करने के लिए नौकरी राज्यों की सूची |
| क्लस्टरनाम | की सरणी तार फ़िल्टरिंग के लिए लागू करने के लिए क्लस्टर नामों की सूची |
| टैग | तार फ़िल्टरिंग के लिए आवेदन करने के लिए टैग की एक अर्धविराम अलग सूची। पैटर्न: कुंजी 1 = मान 1; कुंजी2=मान2 |
| ढूँढ | तार फ़िल्टरिंग के लिए लागू करने के लिए शब्द |
| पृष्ठ | पूर्ण संख्या चूक: 0 लौटाए जाने वाले पृष्ठ की संख्या |
| आकार वाला | पूर्ण संख्या चूक: 10 लौटाए जाने वाले पृष्ठ का आकार |
| जाति | की सरणी तार उदाहरण: क्रमबद्ध करें = नाम में, ASC पेजिंग क्रम परिभाषित करने के लिए लागू किए जाने वाले सॉर्ट नियम |
जवाब
प्रतिक्रिया के नमूने
- 200
{- "पृष्ठ": {
- "संख्या": 0,
- "आकार": 0,
- "ऑफसेट": 0,
- "पृष्ठांकित": सच्चा
}, - "क्रमबद्ध": [
- "स्ट्रिंग"
], - "टोटल एलिमेंट्स": 0,
- "कुल पृष्ठ": 0,
- "पहले": सच्चा,
- "अंतिम": सच्चा,
- "खाली": सच्चा,
- "सामग्री": [
- {
- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "cron": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": { },
- "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "बनाया गया समय": 0,
- "disabledTime": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "नौकरियां": [
- {
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}
]
}Creates a schedule of single Spark jobs
अनुरोध बॉडी स्कीमा: मल्टीपार्ट/फॉर्म-डेटाआवश्यक
| नाम आवश्यक | तार |
| या क़िस्म | तार |
| cron आवश्यक | तार |
| टैग | तार चूक: "कुंजी = मूल्य; कुंजी2=मान2" टैग की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| भाषा | तार चूक: "स्केल" एनम: "स्केल" "पायथन" |
| क्लस्टरनाम आवश्यक | तार चूक: "डिफ़ॉल्ट" |
| जार | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| फ़ाइलें | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| pyFiles | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| jobConfig | तार चूक: "spark.key = मान; स्पार्क.की2=मान2" स्पार्क नौकरी के लिए लागू किए जाने वाले स्पार्क मापदंडों की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| jobClass आवश्यक | तार |
| आर्ग्स | तार list of spark arguments to be applied for the Spark job. |
| pyआवश्यकताएँ | तार अजगर आवश्यकताओं की एक अर्धविराम अलग सूची। पैकेज नाम और संस्करण (यदि दिया गया है) को डबल बराबर चिह्न द्वारा अलग किया जाना चाहिए। |
| packages | तार Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version. |
| startTime | तार The time when the schedule will start in epoch milliseconds (e.g. 1727733600000, which means 01.10.2024). If not provided, the schedule will start immediately. |
| endTime | तार The time when the schedule will be suspended in epoch milliseconds (e.g. 1727820000000, which means 02.10.2024). If not provided, the schedule will create jobs until schedule disabling. |
| maxRetries | तार चूक: 0 Max number of retries to be performed if the job fails |
| executors | तार number of executors to run |
| driverCores | तार Number of cores to use for the driver process. |
| executorCores | तार The number of cores to use on each executor. |
| driverMemory | तार Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| executorMemory | तार Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| dynamicAllocation | तार चूक: "झूठा" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload. |
| initialExecutors | तार Initial number of executors to run if dynamic allocation is enabled. |
| minExecutors | तार Upper bound for the number of executors if dynamic allocation is enabled. |
| maxExecutors | तार Lower bound for the number of executors if dynamic allocation is enabled. |
जवाब
प्रतिक्रिया के नमूने
- 200
- 402
- 404
- 409
{- "scheduleId": "स्ट्रिंग"
}Returns a schedule found by its id
पथ पैरामीटर
| scheduleId आवश्यक | तार The unique identifier of a schedule |
जवाब
प्रतिक्रिया के नमूने
- 200
- 404
{- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "cron": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": { },
- "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "बनाया गया समय": 0,
- "disabledTime": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "नौकरियां": [
- {
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}Updates a schedule by its id
पथ पैरामीटर
| scheduleId आवश्यक | तार The unique identifier of a schedule |
अनुरोध बॉडी स्कीमा: मल्टीपार्ट/फॉर्म-डेटाआवश्यक
| या क़िस्म | तार |
| टैग | तार टैग की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| jobConfig | तार स्पार्क नौकरी के लिए लागू किए जाने वाले स्पार्क मापदंडों की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| cron | तार Cron expression to be applied for the schedule |
| आर्ग्स | तार स्पार्क नौकरी के लिए लागू होने वाले स्पार्क तर्कों की एक अर्धविराम अलग सूची। |
| jobClass | तार |
| pyआवश्यकताएँ | तार अजगर आवश्यकताओं की एक अर्धविराम अलग सूची। पैकेज नाम और संस्करण (यदि दिया गया है) को डबल बराबर चिह्न द्वारा अलग किया जाना चाहिए। |
| packages | तार Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version. |
| startTime | तार The time when the schedule will start in epoch milliseconds (e.g. 1727733600000, which means 01.10.2024). If not provided, the schedule will start immediately. |
| endTime | तार The time when the schedule will be suspended in epoch milliseconds (e.g. 1727820000000, which means 02.10.2024). If not provided, the schedule will create jobs until schedule disabling. |
| maxRetries | तार Max number of retries to be performed if the job fails |
| executors | तार number of executors to run |
| driverCores | तार Number of cores to use for the driver process. |
| executorCores | तार The number of cores to use on each executor. |
| driverMemory | तार Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| executorMemory | तार Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| dynamicAllocation | तार चूक: "झूठा" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload. |
| initialExecutors | तार Initial number of executors to run if dynamic allocation is enabled. |
| minExecutors | तार Upper bound for the number of executors if dynamic allocation is enabled. |
| maxExecutors | तार Lower bound for the number of executors if dynamic allocation is enabled. |
जवाब
प्रतिक्रिया के नमूने
- 402
- 404
- 409
{- "संदेश": "स्ट्रिंग"
}Returns a schedule found by its name
पथ पैरामीटर
| scheduleName आवश्यक | तार The unique name of a schedule |
जवाब
प्रतिक्रिया के नमूने
- 200
- 404
{- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "cron": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": { },
- "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "बनाया गया समय": 0,
- "disabledTime": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "नौकरियां": [
- {
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}मौजूदा नौकरियों का एक पेज लौटाता है
सवाल पैरामीटर
| नौकरी के प्रकार | की सरणी तार (नौकरी प्रकार) आइटम एनम: "सिंगल" "इंटरैक्टिव" "शैल" फ़िल्टरिंग के लिए आवेदन करने के लिए नौकरी के प्रकारों की सूची |
| नौकरी राज्य | की सरणी तार (नौकरीराज्य) चूक: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" आइटम एनम: "सबमिट किया गया" "शुरू" "तैयार" "व्यस्त" "विफल" "समाप्त" "CANCELED" "अज्ञात" फ़िल्टरिंग के लिए आवेदन करने के लिए नौकरी राज्यों की सूची |
| क्लस्टरनाम | की सरणी तार फ़िल्टरिंग के लिए लागू करने के लिए क्लस्टर नामों की सूची |
| टैग | तार फ़िल्टरिंग के लिए आवेदन करने के लिए टैग की एक अर्धविराम अलग सूची। पैटर्न: कुंजी 1 = मान 1; कुंजी2=मान2 |
| ढूँढ | तार फ़िल्टरिंग के लिए लागू करने के लिए शब्द |
| पृष्ठ | पूर्ण संख्या चूक: 0 लौटाए जाने वाले पृष्ठ की संख्या |
| आकार वाला | पूर्ण संख्या चूक: 10 लौटाए जाने वाले पृष्ठ का आकार |
| जाति | की सरणी तार उदाहरण: क्रमबद्ध करें = नाम में, ASC पेजिंग क्रम परिभाषित करने के लिए लागू किए जाने वाले सॉर्ट नियम |
जवाब
प्रतिक्रिया के नमूने
- 200
{- "पृष्ठ": {
- "संख्या": 0,
- "आकार": 0,
- "ऑफसेट": 0,
- "पृष्ठांकित": सच्चा
}, - "क्रमबद्ध": [
- "स्ट्रिंग"
], - "टोटल एलिमेंट्स": 0,
- "कुल पृष्ठ": 0,
- "पहले": सच्चा,
- "अंतिम": सच्चा,
- "खाली": सच्चा,
- "सामग्री": [
- {
- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}अपनी आईडी द्वारा मिली नौकरी लौटाता है
पथ पैरामीटर
| जॉब आईडी आवश्यक | तार किसी कार्य का युनीक आइडेंटिफ़ायर |
जवाब
प्रतिक्रिया के नमूने
- 200
- 404
{- "जॉब आईडी": "स्ट्रिंग",
- "समूहआईडी": "स्ट्रिंग",
- "scheduleId": "स्ट्रिंग",
- "नौकरी का नाम": "स्ट्रिंग",
- "नौकरी का प्रकार": "स्ट्रिंग",
- "टैग": "स्ट्रिंग",
- "भाषा": "स्ट्रिंग",
- "नौकरी वर्ग": "स्ट्रिंग",
- "क्लस्टरनाम": "स्ट्रिंग",
- "jobConfig": "स्ट्रिंग",
- "args": [
- "स्ट्रिंग"
], - "pyRequirements": "स्ट्रिंग",
- "packages": "स्ट्रिंग",
- "ऐपआईडी": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "त्रुटि": "स्ट्रिंग",
- "सबमिट टाइम": 0,
- "स्टार्टटाइम": 0,
- "समाप्ति समय": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}सभी कार्य संसाधनों के लिए लॉग लौटाता है
पथ पैरामीटर
| जॉब आईडी आवश्यक | तार किसी कार्य का युनीक आइडेंटिफ़ायर |
सवाल पैरामीटर
| लॉगसाइज | पूर्ण संख्या <इंट64> चूक: 100 लौटने के लिए लॉग लाइनों की अधिकतम संख्या। एपीआई में सीमा 25000 लाइनों पर सेट है, आप इलम-कोर की कॉन्फ़िगरेशन फ़ाइल में ilum.api.job.logs.maxLines पैरामीटर सेट करके इसे बदल सकते हैं |
| से | पूर्ण संख्या <इंट64> चूक: 0 लॉग की शुरुआत से ऑफसेट |
जवाब
प्रतिक्रिया के नमूने
- 200
- 404
[- {
- "नाम": "स्ट्रिंग",
- "प्रकार": "स्ट्रिंग",
- "भूमिका": "स्ट्रिंग",
- "राज्य": "स्ट्रिंग",
- "से": 0,
- "लॉगसाइज़": 0,
- "फ़ाइल का नाम": "स्ट्रिंग",
- "लॉग": [
- "स्ट्रिंग"
]
}
]एकल स्पार्क कार्य सबमिट करता है
अनुरोध बॉडी स्कीमा: मल्टीपार्ट/फॉर्म-डेटाआवश्यक
| नाम आवश्यक | तार |
| टैग | तार चूक: "कुंजी = मूल्य; कुंजी2=मान2" टैग की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| भाषा | तार चूक: "स्केल" एनम: "स्केल" "पायथन" |
| क्लस्टरनाम आवश्यक | तार चूक: "डिफ़ॉल्ट" |
| jobClass | तार |
| जार | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| फ़ाइलें | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| pyFiles | की सरणी तार <द्वि-अंगी> [ आइटम <द्वि-अंगी > ] |
| jobConfig | तार चूक: "spark.key = मान; स्पार्क.की2=मान2" स्पार्क नौकरी के लिए लागू किए जाने वाले स्पार्क मापदंडों की एक अर्धविराम अलग सूची। पैरामीटर कुंजी और मान को एक बराबर चिह्न से अलग किया जाना चाहिए। |
| pyआवश्यकताएँ | तार अजगर आवश्यकताओं की एक अर्धविराम अलग सूची। पैकेज नाम और संस्करण (यदि दिया गया है) को डबल बराबर चिह्न द्वारा अलग किया जाना चाहिए। |
| packages | तार Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version. |
| आर्ग्स | तार स्पार्क नौकरी के लिए लागू होने वाले स्पार्क तर्कों की एक अर्धविराम अलग सूची। |
| maxRetries | तार चूक: 0 Max number of retries to be performed if the job fails |
| executors | तार number of executors to run |
| driverCores | तार Number of cores to use for the driver process. |
| executorCores | तार The number of cores to use on each executor. |
| driverMemory | तार Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| executorMemory | तार Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g). |
| dynamicAllocation | तार चूक: "झूठा" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload. |
| initialExecutors | तार Initial number of executors to run if dynamic allocation is enabled. |
| minExecutors | तार Upper bound for the number of executors if dynamic allocation is enabled. |
| maxExecutors | तार Lower bound for the number of executors if dynamic allocation is enabled. |
जवाब
प्रतिक्रिया के नमूने
- 200
- 402
- 404
- 409
{- "जॉब आईडी": "स्ट्रिंग"
}स्पार्क नौकरी परिवर्तन की एक धारा देता है
सवाल पैरामीटर
| जॉब आईडी | की सरणी तार फ़िल्टरिंग के लिए आवेदन करने के लिए नौकरी आईडी की सूची |
| ग्रुपआईडी | की सरणी तार फ़िल्टरिंग के लिए आवेदन करने के लिए समूह आईडी की सूची |
| क्लस्टरनाम | की सरणी तार फ़िल्टरिंग के लिए लागू करने के लिए क्लस्टर नामों की सूची |
| टैग | तार फ़िल्टरिंग के लिए आवेदन करने के लिए टैग की एक अर्धविराम अलग सूची। पैटर्न: कुंजी 1 = मान 1; कुंजी2=मान2 |
जवाब
क्लस्टर परिभाषा बनाता है
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| नाम आवश्यक | तार |
| या क़िस्म | तार |
वस्तु | |
| स्पार्कस्टोरेज | तार चूक: "एस 3" |
| metastoreName | तार |
वस्तु (memorySettingsCreation) | |
| defaultApplicationConfig | तार |
| प्रकार आवश्यक | तार चूक: "के 8 एस" |
| यूआरएल आवश्यक | तार |
| सीएसीईआरटी | तार |
| क्लाइंटसर्ट | तार |
| क्लाइंटकी | तार |
| क्लाइंटकीएल्गोरिथम | तार |
| क्लाइंटकीपासफ्रेज़ | तार |
| उपयोगकर्ता नाम | तार |
| पासवर्ड | तार |
वस्तु (clusterResourceQuota) | |
वस्तु (clusterLimitRange) |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "भंडारण": {
- "प्रॉपर्टी1": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}, - "प्रॉपर्टी2": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}
}, - "स्पार्कस्टोरेज": "एस 3",
- "metastoreName": "स्ट्रिंग",
- "memorySettings": {
- "executors": "स्ट्रिंग",
- "driverCores": "स्ट्रिंग",
- "executorCores": "स्ट्रिंग",
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": "झूठा",
- "initialExecutors": "स्ट्रिंग",
- "minExecutors": "स्ट्रिंग",
- "maxExecutors": "स्ट्रिंग"
}, - "defaultApplicationConfig": "स्ट्रिंग",
- "प्रकार": "के 8 एस",
- "यूआरएल": "स्ट्रिंग",
- "सीएसर्ट": "स्ट्रिंग",
- "क्लाइंटसर्ट": "स्ट्रिंग",
- "क्लाइंटकी": "स्ट्रिंग",
- "क्लाइंटकीएल्गोरिथम": "स्ट्रिंग",
- "क्लाइंटकीपासफ़्रेज़": "स्ट्रिंग",
- "उपयोगकर्ता नाम": "स्ट्रिंग",
- "पासवर्ड": "स्ट्रिंग",
- "resourceQuota": {
- "limitsPod": "स्ट्रिंग",
- "limitsCpu": "स्ट्रिंग",
- "limitsMemory": "स्ट्रिंग",
- "requestsCpu": "स्ट्रिंग",
- "requestsMemory": "स्ट्रिंग"
}, - "limitRange": {
- "cpuLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}, - "memoryLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}
}
}प्रतिक्रिया के नमूने
- 200
- 402
- 409
{- "क्लस्टरआईडी": "स्ट्रिंग"
}मौजूदा क्लस्टर का एक पृष्ठ देता है
सवाल पैरामीटर
| ढूँढ | तार फ़िल्टरिंग के लिए लागू करने के लिए शब्द |
| पृष्ठ | पूर्ण संख्या चूक: 0 लौटाए जाने वाले पृष्ठ की संख्या |
| आकार वाला | पूर्ण संख्या चूक: 10 लौटाए जाने वाले पृष्ठ का आकार |
| जाति | की सरणी तार उदाहरण: क्रमबद्ध करें = नाम में, ASC पेजिंग क्रम परिभाषित करने के लिए लागू किए जाने वाले सॉर्ट नियम |
जवाब
प्रतिक्रिया के नमूने
- 200
{- "पृष्ठ": {
- "संख्या": 0,
- "आकार": 0,
- "ऑफसेट": 0,
- "पृष्ठांकित": सच्चा
}, - "क्रमबद्ध": [
- "स्ट्रिंग"
], - "टोटल एलिमेंट्स": 0,
- "कुल पृष्ठ": 0,
- "पहले": सच्चा,
- "अंतिम": सच्चा,
- "खाली": सच्चा,
- "सामग्री": [
- {
- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "स्पार्कमास्टर": "स्ट्रिंग",
- "स्पार्कडिप्लॉयमोड": "स्ट्रिंग",
- "स्पार्कस्टोरेज": "स्ट्रिंग",
- "metastoreName": "स्ट्रिंग",
- "भंडारण": {
- "प्रॉपर्टी1": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}, - "प्रॉपर्टी2": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}
}, - "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "defaultApplicationConfig": "स्ट्रिंग",
- "प्रकार": "के 8 एस",
- "यूआरएल": "स्ट्रिंग",
- "सीएसर्ट": "स्ट्रिंग",
- "क्लाइंटसर्ट": "स्ट्रिंग",
- "क्लाइंटकी": "स्ट्रिंग",
- "क्लाइंटकीएल्गोरिथम": "स्ट्रिंग",
- "क्लाइंटकीपासफ़्रेज़": "स्ट्रिंग",
- "उपयोगकर्ता नाम": "स्ट्रिंग",
- "पासवर्ड": "स्ट्रिंग",
- "resourceQuota": {
- "limitsPod": "स्ट्रिंग",
- "limitsCpu": "स्ट्रिंग",
- "limitsMemory": "स्ट्रिंग",
- "requestsCpu": "स्ट्रिंग",
- "requestsMemory": "स्ट्रिंग"
}, - "limitRange": {
- "cpuLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}, - "memoryLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}
}
}
]
}इसकी id द्वारा पाया गया क्लस्टर लौटाता है
पथ पैरामीटर
| क्लस्टरआईडी आवश्यक | तार क्लस्टर का युनीक आइडेंटिफ़ायर |
जवाब
प्रतिक्रिया के नमूने
- 200
- 404
{- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "स्पार्कमास्टर": "स्ट्रिंग",
- "स्पार्कडिप्लॉयमोड": "स्ट्रिंग",
- "स्पार्कस्टोरेज": "स्ट्रिंग",
- "metastoreName": "स्ट्रिंग",
- "भंडारण": {
- "प्रॉपर्टी1": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}, - "प्रॉपर्टी2": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}
}, - "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": सच्चा,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "defaultApplicationConfig": "स्ट्रिंग",
- "प्रकार": "के 8 एस",
- "यूआरएल": "स्ट्रिंग",
- "सीएसर्ट": "स्ट्रिंग",
- "क्लाइंटसर्ट": "स्ट्रिंग",
- "क्लाइंटकी": "स्ट्रिंग",
- "क्लाइंटकीएल्गोरिथम": "स्ट्रिंग",
- "क्लाइंटकीपासफ़्रेज़": "स्ट्रिंग",
- "उपयोगकर्ता नाम": "स्ट्रिंग",
- "पासवर्ड": "स्ट्रिंग",
- "resourceQuota": {
- "limitsPod": "स्ट्रिंग",
- "limitsCpu": "स्ट्रिंग",
- "limitsMemory": "स्ट्रिंग",
- "requestsCpu": "स्ट्रिंग",
- "requestsMemory": "स्ट्रिंग"
}, - "limitRange": {
- "cpuLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}, - "memoryLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}
}
}Updates a cluster by its id
पथ पैरामीटर
| क्लस्टरआईडी आवश्यक | तार क्लस्टर का युनीक आइडेंटिफ़ायर |
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| नाम आवश्यक | तार |
| या क़िस्म | तार |
वस्तु | |
| स्पार्कस्टोरेज | तार चूक: "एस 3" |
| metastoreName | तार |
वस्तु (memorySettingsCreation) | |
| defaultApplicationConfig | तार |
| प्रकार आवश्यक | तार चूक: "के 8 एस" |
| यूआरएल आवश्यक | तार |
| सीएसीईआरटी | तार |
| क्लाइंटसर्ट | तार |
| क्लाइंटकी | तार |
| क्लाइंटकीएल्गोरिथम | तार |
| क्लाइंटकीपासफ्रेज़ | तार |
| उपयोगकर्ता नाम | तार |
| पासवर्ड | तार |
वस्तु (clusterResourceQuota) | |
वस्तु (clusterLimitRange) |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "नाम": "स्ट्रिंग",
- "विवरण": "स्ट्रिंग",
- "भंडारण": {
- "प्रॉपर्टी1": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}, - "प्रॉपर्टी2": {
- "स्पार्कबकेट": "स्ट्रिंग",
- "डेटाबकेट": "स्ट्रिंग",
- "extraBuckets": [
- "स्ट्रिंग"
], - "प्रकार": "एस 3",
- "समापन बिंदु": "स्ट्रिंग",
- "region": "us-east-1",
- "एक्सेसकुंजी": "स्ट्रिंग",
- "गुप्त कुंजी": "स्ट्रिंग"
}
}, - "स्पार्कस्टोरेज": "एस 3",
- "metastoreName": "स्ट्रिंग",
- "memorySettings": {
- "executors": "स्ट्रिंग",
- "driverCores": "स्ट्रिंग",
- "executorCores": "स्ट्रिंग",
- "driverMemory": "स्ट्रिंग",
- "executorMemory": "स्ट्रिंग",
- "dynamicAllocation": "झूठा",
- "initialExecutors": "स्ट्रिंग",
- "minExecutors": "स्ट्रिंग",
- "maxExecutors": "स्ट्रिंग"
}, - "defaultApplicationConfig": "स्ट्रिंग",
- "प्रकार": "के 8 एस",
- "यूआरएल": "स्ट्रिंग",
- "सीएसर्ट": "स्ट्रिंग",
- "क्लाइंटसर्ट": "स्ट्रिंग",
- "क्लाइंटकी": "स्ट्रिंग",
- "क्लाइंटकीएल्गोरिथम": "स्ट्रिंग",
- "क्लाइंटकीपासफ़्रेज़": "स्ट्रिंग",
- "उपयोगकर्ता नाम": "स्ट्रिंग",
- "पासवर्ड": "स्ट्रिंग",
- "resourceQuota": {
- "limitsPod": "स्ट्रिंग",
- "limitsCpu": "स्ट्रिंग",
- "limitsMemory": "स्ट्रिंग",
- "requestsCpu": "स्ट्रिंग",
- "requestsMemory": "स्ट्रिंग"
}, - "limitRange": {
- "cpuLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}, - "memoryLimitRange": {
- "defaultLimit": "स्ट्रिंग",
- "defaultRequest": "स्ट्रिंग",
- "minRequest": "स्ट्रिंग",
- "maxLimit": "स्ट्रिंग",
- "maxLimitRequestRatio": "स्ट्रिंग"
}
}
}प्रतिक्रिया के नमूने
- 402
- 404
- 409
{- "संदेश": "स्ट्रिंग"
}Creates an SQL engine
पथ पैरामीटर
| क्लस्टरआईडी आवश्यक | तार क्लस्टर का युनीक आइडेंटिफ़ायर |
अनुरोध बॉडी स्कीमा: आवेदन/JSON
| प्रकार | तार (sqlEngineType) चूक: "SPARK_SQL" एनम: "SPARK_SQL" "TRINO" |
| async | boolean चूक: गलत If true, the request will return immediately, meaning that the engine may not be started yet |
| force | boolean चूक: गलत If true, when there is a starting engine, it will be stopped and a new one will be started |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "प्रकार": "SPARK_SQL",
- "async": गलत,
- "force": गलत
}प्रतिक्रिया के नमूने
- 200
- 402
- 409
{- "आईडी": "स्ट्रिंग"
}Executes an SQL statement
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| statement आवश्यक | तार |
| क्लस्टरआईडी | तार |
| maxRows | पूर्ण संख्या <इंट64> चूक: 1000 |
| engine | तार (sqlEngineType) चूक: "SPARK_SQL" एनम: "SPARK_SQL" "TRINO" |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "statement": "स्ट्रिंग",
- "क्लस्टरआईडी": "स्ट्रिंग",
- "maxRows": 1000,
- "engine": "SPARK_SQL"
}प्रतिक्रिया के नमूने
- 200
- 402
- 409
{- "info": {
- "राज्य": "स्ट्रिंग",
- "creationTime": 0,
- "स्टार्टटाइम": 0,
- "completionTime": 0,
- "exception": "स्ट्रिंग"
}, - "columns": [
- {
- "नाम": "स्ट्रिंग",
- "प्रकार": "स्ट्रिंग",
- "index": 0,
- "precision": 0,
- "पैमाना": 0,
- "comment": "स्ट्रिंग"
}
], - "rows": [
- [
- { }
]
], - "logs": [
- "स्ट्रिंग"
]
}Returns paginated list of saved SQL statements
सवाल पैरामीटर
| पृष्ठ | पूर्ण संख्या चूक: 0 लौटाए जाने वाले पृष्ठ की संख्या |
| आकार वाला | पूर्ण संख्या चूक: 10 लौटाए जाने वाले पृष्ठ का आकार |
| जाति | की सरणी तार उदाहरण: क्रमबद्ध करें = नाम में, ASC पेजिंग क्रम परिभाषित करने के लिए लागू किए जाने वाले सॉर्ट नियम |
| ढूँढ | तार फ़िल्टरिंग के लिए लागू करने के लिए शब्द |
जवाब
प्रतिक्रिया के नमूने
- 200
- 409
{- "पृष्ठ": {
- "संख्या": 0,
- "आकार": 0,
- "ऑफसेट": 0,
- "पृष्ठांकित": सच्चा
}, - "क्रमबद्ध": [
- "स्ट्रिंग"
], - "टोटल एलिमेंट्स": 0,
- "कुल पृष्ठ": 0,
- "पहले": सच्चा,
- "अंतिम": सच्चा,
- "खाली": सच्चा,
- "सामग्री": [
- {
- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "statement": "स्ट्रिंग",
- "engine": "SPARK_SQL",
- "maxRows": 0
}
]
}Saves an SQL statement
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| नाम आवश्यक | तार |
| statement आवश्यक | तार |
| engine | तार (sqlEngineType) चूक: "SPARK_SQL" एनम: "SPARK_SQL" "TRINO" |
| maxRows | पूर्ण संख्या <इंट64> |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "नाम": "स्ट्रिंग",
- "statement": "स्ट्रिंग",
- "engine": "SPARK_SQL",
- "maxRows": 0
}प्रतिक्रिया के नमूने
- 200
- 402
- 409
{- "आईडी": "स्ट्रिंग"
}Updates a saved SQL statement found by its id
पथ पैरामीटर
| sqlSavedId आवश्यक | तार The unique identifier of a saved SQL statement |
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| नाम आवश्यक | तार |
| statement आवश्यक | तार |
| engine | तार (sqlEngineType) चूक: "SPARK_SQL" एनम: "SPARK_SQL" "TRINO" |
| maxRows | पूर्ण संख्या <इंट64> |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "नाम": "स्ट्रिंग",
- "statement": "स्ट्रिंग",
- "engine": "SPARK_SQL",
- "maxRows": 0
}प्रतिक्रिया के नमूने
- 402
- 404
{- "संदेश": "स्ट्रिंग"
}Returns a page of SQL notebooks
सवाल पैरामीटर
| पृष्ठ | पूर्ण संख्या चूक: 0 लौटाए जाने वाले पृष्ठ की संख्या |
| आकार वाला | पूर्ण संख्या चूक: 10 लौटाए जाने वाले पृष्ठ का आकार |
| जाति | की सरणी तार उदाहरण: क्रमबद्ध करें = नाम में, ASC पेजिंग क्रम परिभाषित करने के लिए लागू किए जाने वाले सॉर्ट नियम |
| ढूँढ | तार फ़िल्टरिंग के लिए लागू करने के लिए शब्द |
जवाब
प्रतिक्रिया के नमूने
- 200
- 409
{- "पृष्ठ": {
- "संख्या": 0,
- "आकार": 0,
- "ऑफसेट": 0,
- "पृष्ठांकित": सच्चा
}, - "क्रमबद्ध": [
- "स्ट्रिंग"
], - "टोटल एलिमेंट्स": 0,
- "कुल पृष्ठ": 0,
- "पहले": सच्चा,
- "अंतिम": सच्चा,
- "खाली": सच्चा,
- "सामग्री": [
- {
- "आईडी": "स्ट्रिंग",
- "नाम": "स्ट्रिंग",
- "statements": [
- {
- "आईडी": "स्ट्रिंग",
- "भाषा": "SQL",
- "code": "स्ट्रिंग"
}
]
}
]
}Creates an SQL notebook
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| नाम | तार |
की सरणी objects (sqlNotebookCell) |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "नाम": "स्ट्रिंग",
- "statements": [
- {
- "आईडी": "स्ट्रिंग",
- "भाषा": "SQL",
- "code": "स्ट्रिंग"
}
]
}प्रतिक्रिया के नमूने
- 200
- 402
- 409
{- "आईडी": "स्ट्रिंग"
}Updates an SQL notebook found by its id
पथ पैरामीटर
| sqlNotebookId आवश्यक | तार The unique identifier of an SQL notebook |
अनुरोध बॉडी स्कीमा: आवेदन/JSONआवश्यक
| नाम | तार |
की सरणी objects (sqlNotebookCell) |
जवाब
नमूने का अनुरोध करें
- पेलोड
{- "नाम": "स्ट्रिंग",
- "statements": [
- {
- "आईडी": "स्ट्रिंग",
- "भाषा": "SQL",
- "code": "स्ट्रिंग"
}
]
}प्रतिक्रिया के नमूने
- 402
- 404
- 409
{- "संदेश": "स्ट्रिंग"
}