إرجاع صفحة من المجموعات الموجودة
استفسار البارامترات
| مجموعة الدول | مجموعة من سلاسل (مجموعة الدولة) العناصر تعداد: "نشط" "مؤرشف" قائمة حالات المجموعة التي ستتقدم بطلب للتصفية |
| مجموعة الأنواع | مجموعة من سلاسل (مجموعةنوع) العناصر تعداد: "وظيفة" "الرمز" قائمة أنواع المجموعات المراد التقدم بطلب للتصفية |
| وظائف الدول | مجموعة من سلاسل (jobState) افتراضي: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" العناصر تعداد: "تم التقديم" "البدء" "جاهز" "مشغول" "فشل" "انتهى" "CANCELED" "غير معروف" قائمة حالات الوظيفة التي يجب التقدم بطلب للحصول على الفلترة |
| clusterNames | مجموعة من سلاسل قائمة أسماء نظام المجموعة المراد تطبيقها على التصفية |
| العلامات | خيط قائمة مفصولة بفاصلة منقوطة من العلامات للتقدم بطلب للتصفية. النمط: key1 = value1 ؛ المفتاح 2 = القيمة 2 |
| بحث | خيط الكلمة التي يجب التقدم بطلب للتصفية |
| صفحة | العدد الصحيح افتراضي: 0 عدد الصفحات المراد إرجاعها |
| حجم | العدد الصحيح افتراضي: 10 حجم الصفحة المراد إرجاعها |
| صنف | مجموعة من سلاسل مثل: فرز = اسم ، ASC قواعد الفرز التي سيتم تطبيقها لتعريف ترتيب ترحيل الصفحات |
الاستجابات
عينات الاستجابة
- 200
{- "الصفحة": {
- "رقم": 0,
- "الحجم": 0,
- "الإزاحة": 0,
- "صفحة": صحيح
}, - "فرز": [
- "سلسلة"
], - "totalElements": 0,
- "إجمالي الصفحات": 0,
- "أولا": صحيح,
- "الأخير": صحيح,
- "فارغ": صحيح,
- "المحتوى": [
- {
- "المعرف": "سلسلة",
- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "طيب": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "clusterName": "سلسلة",
- "الدولة": "سلسلة",
- "مقياس": 0,
- "jobConfig": { },
- "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "createdTime": 0,
- "أرشفة الوقت": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "autoPause": صحيح,
- "وظائف": [
- {
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "scheduleId": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 0,
- "وقت البدء": 0,
- "نهاية الوقت": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}
]
}إنشاء مجموعة من وظائف Spark التفاعلية
طلب مخطط الجسم: بيانات متعددة الأجزاء / النماذجمطلوب
| اسم مطلوب | خيط |
| وصف | خيط |
| نوع | خيط افتراضي: "وظيفة" تعداد: "وظيفة" "الرمز" |
| العلامات | خيط افتراضي: "المفتاح = القيمة. المفتاح 2 = القيمة 2 " قائمة علامات مفصولة بفاصلة منقوطة. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| اللغة | خيط افتراضي: "سكالا" تعداد: "سكالا" "بايثون" |
| clusterName مطلوب | خيط افتراضي: "افتراضي" |
| الجرار | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| الملفات | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| pyFiles | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| jobConfig | خيط افتراضي: "spark.key = القيمة. spark.key2 = القيمة 2 " قائمة منفصلة بفاصلة منقوطة لمعلمات الشرارة التي سيتم تطبيقها على وظيفة Spark. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| متطلبات py | خيط قائمة منفصلة بفاصلة منقوطة لمتطلبات python. يجب فصل اسم الحزمة وإصدارها (إذا تم تقديمه) بعلامة مساواة مزدوجة. |
| 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 عدد عدد صحيح من وظائف Spark التي سيتم إطلاقها ضمن هذه المجموعة |
| 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
{- "معرف المجموعة": "سلسلة"
}إرجاع مجموعة تم العثور عليها بواسطة المعرف الخاص بها
مسار البارامترات
| معرف المجموعة مطلوب | خيط المعرف الفريد للمجموعة |
الاستجابات
عينات الاستجابة
- 200
- 404
{- "المعرف": "سلسلة",
- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "طيب": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "clusterName": "سلسلة",
- "الدولة": "سلسلة",
- "مقياس": 0,
- "jobConfig": { },
- "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "createdTime": 0,
- "أرشفة الوقت": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "autoPause": صحيح,
- "وظائف": [
- {
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "scheduleId": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 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 | خيط قائمة منفصلة بفاصلة منقوطة لمعلمات الشرارة التي سيتم تطبيقها على وظيفة Spark. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| متطلبات py | خيط قائمة منفصلة بفاصلة منقوطة لمتطلبات python. يجب فصل اسم الحزمة وإصدارها (إذا تم تقديمه) بعلامة مساواة مزدوجة. |
| packages | خيط Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version. |
| مِيزَان | خيط عدد عدد صحيح من وظائف Spark التي سيتم إطلاقها ضمن هذه المجموعة |
| 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
{- "رسالة": "سلسلة"
}تنفيذ مهمة Spark تفاعلية داخل المجموعة المختارة
ينفذ مهمة Spark تفاعلية داخل المجموعة المختارة وينتظر اكتمال مثيل الوظيفة. يتم إرجاع نتيجته كرد فعل.
مسار البارامترات
| معرف المجموعة مطلوب | خيط المعرف الفريد للمجموعة |
طلب مخطط الجسم: التطبيق / JSONمطلوب
| نوع مطلوب | خيط افتراضي: "interactive_job_execute" |
| فئة الوظيفة مطلوب | خيط |
مطلوب | كائن |
الاستجابات
طلب عينات
- حموله
{- "النوع": "interactive_job_execute",
- "jobClass": "سلسلة",
- "jobConfig": { }
}عينات الاستجابة
- 200
- 402
- 404
- 409
{- "jobInstanceId": "سلسلة",
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "وقت البدء": 0,
- "نهاية الوقت": 0,
- "jobClass": "سلسلة",
- "jobConfig": { },
- "النتيجة": "سلسلة",
- "خطأ": {
- "رسالة": "سلسلة",
- "stackTrace": "سلسلة"
}
}إرجاع صفحة من نتائج مثيل وظيفة المجموعة الموجودة
مسار البارامترات
| معرف المجموعة مطلوب | خيط المعرف الفريد للمجموعة |
استفسار البارامترات
| بحث | خيط الكلمة التي يجب التقدم بطلب للتصفية |
| صفحة | العدد الصحيح افتراضي: 0 عدد الصفحات المراد إرجاعها |
| حجم | العدد الصحيح افتراضي: 10 حجم الصفحة المراد إرجاعها |
| صنف | مجموعة من سلاسل مثل: فرز = اسم ، ASC قواعد الفرز التي سيتم تطبيقها لتعريف ترتيب ترحيل الصفحات |
الاستجابات
عينات الاستجابة
- 200
{- "الصفحة": {
- "رقم": 0,
- "الحجم": 0,
- "الإزاحة": 0,
- "صفحة": صحيح
}, - "فرز": [
- "سلسلة"
], - "totalElements": 0,
- "إجمالي الصفحات": 0,
- "أولا": صحيح,
- "الأخير": صحيح,
- "فارغ": صحيح,
- "المحتوى": [
- {
- "jobInstanceId": "سلسلة",
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "وقت البدء": 0,
- "نهاية الوقت": 0,
- "jobClass": "سلسلة",
- "jobConfig": { },
- "النتيجة": "سلسلة",
- "خطأ": {
- "رسالة": "سلسلة",
- "stackTrace": "سلسلة"
}
}
]
}إرسال وظيفة Spark تفاعلية ضمن المجموعة المختارة
إرسال وظيفة Spark تفاعلية داخل المجموعة المختارة. لا ينتظر حتى تكتمل المهمة. بدلا من ذلك ، يقوم بإرجاع معرف مثيل الوظيفة الذي تم إنشاؤه. يمكن جلب نتيجتها من خلال نتيجة مثيل الوظيفة تحديث الاشتراك.
مسار البارامترات
| معرف المجموعة مطلوب | خيط المعرف الفريد للمجموعة |
طلب مخطط الجسم: التطبيق / JSONمطلوب
| نوع مطلوب | خيط افتراضي: "interactive_job_execute" |
| فئة الوظيفة مطلوب | خيط |
مطلوب | كائن |
الاستجابات
طلب عينات
- حموله
{- "النوع": "interactive_job_execute",
- "jobClass": "سلسلة",
- "jobConfig": { }
}عينات الاستجابة
- 200
- 402
- 404
- 409
{- "jobInstanceId": "سلسلة"
}إرجاع دفق من التغييرات التفاعلية في نتائج مهمة Spark
استفسار البارامترات
| معرفات الوظائف | مجموعة من سلاسل قائمة معرفات الوظائف المراد التقدم للتصفية |
| معرفات المجموعة | مجموعة من سلاسل قائمة معرفات المجموعة التي يجب التقدم بطلب للتصفية |
| clusterNames | مجموعة من سلاسل قائمة أسماء نظام المجموعة المراد تطبيقها على التصفية |
| أسماء المجموعات | مجموعة من سلاسل قائمة أسماء المجموعات المراد التقدم بطلب للتصفية |
| العلامات | خيط قائمة مفصولة بفاصلة منقوطة من العلامات للتقدم بطلب للتصفية. النمط: key1 = value1 ؛ المفتاح 2 = القيمة 2 |
الاستجابات
إرجاع مجموعة تم العثور عليها باسمها
مسار البارامترات
| اسم المجموعة مطلوب | خيط الاسم الفريد للمجموعة |
الاستجابات
عينات الاستجابة
- 200
- 404
{- "المعرف": "سلسلة",
- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "طيب": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "clusterName": "سلسلة",
- "الدولة": "سلسلة",
- "مقياس": 0,
- "jobConfig": { },
- "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "createdTime": 0,
- "أرشفة الوقت": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "autoPause": صحيح,
- "وظائف": [
- {
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "scheduleId": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 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 |
| وظائف الدول | مجموعة من سلاسل (jobState) افتراضي: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" العناصر تعداد: "تم التقديم" "البدء" "جاهز" "مشغول" "فشل" "انتهى" "CANCELED" "غير معروف" قائمة حالات الوظيفة التي يجب التقدم بطلب للحصول على الفلترة |
| clusterNames | مجموعة من سلاسل قائمة أسماء نظام المجموعة المراد تطبيقها على التصفية |
| العلامات | خيط قائمة مفصولة بفاصلة منقوطة من العلامات للتقدم بطلب للتصفية. النمط: key1 = value1 ؛ المفتاح 2 = القيمة 2 |
| بحث | خيط الكلمة التي يجب التقدم بطلب للتصفية |
| صفحة | العدد الصحيح افتراضي: 0 عدد الصفحات المراد إرجاعها |
| حجم | العدد الصحيح افتراضي: 10 حجم الصفحة المراد إرجاعها |
| صنف | مجموعة من سلاسل مثل: فرز = اسم ، ASC قواعد الفرز التي سيتم تطبيقها لتعريف ترتيب ترحيل الصفحات |
الاستجابات
عينات الاستجابة
- 200
{- "الصفحة": {
- "رقم": 0,
- "الحجم": 0,
- "الإزاحة": 0,
- "صفحة": صحيح
}, - "فرز": [
- "سلسلة"
], - "totalElements": 0,
- "إجمالي الصفحات": 0,
- "أولا": صحيح,
- "الأخير": صحيح,
- "فارغ": صحيح,
- "المحتوى": [
- {
- "المعرف": "سلسلة",
- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "cron": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": { },
- "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "الدولة": "سلسلة",
- "jobClass": "سلسلة",
- "args": [
- "سلسلة"
], - "وقت البدء": 0,
- "نهاية الوقت": 0,
- "maxRetries": 0,
- "createdTime": 0,
- "disabledTime": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "وظائف": [
- {
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "scheduleId": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 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 " قائمة علامات مفصولة بفاصلة منقوطة. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| اللغة | خيط افتراضي: "سكالا" تعداد: "سكالا" "بايثون" |
| clusterName مطلوب | خيط افتراضي: "افتراضي" |
| الجرار | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| الملفات | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| pyFiles | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| jobConfig | خيط افتراضي: "spark.key = القيمة. spark.key2 = القيمة 2 " قائمة منفصلة بفاصلة منقوطة لمعلمات الشرارة التي سيتم تطبيقها على وظيفة Spark. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| فئة الوظيفة مطلوب | خيط |
| أرجس | خيط list of spark arguments to be applied for the Spark job. |
| متطلبات py | خيط قائمة منفصلة بفاصلة منقوطة لمتطلبات python. يجب فصل اسم الحزمة وإصدارها (إذا تم تقديمه) بعلامة مساواة مزدوجة. |
| 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": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": { },
- "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "الدولة": "سلسلة",
- "jobClass": "سلسلة",
- "args": [
- "سلسلة"
], - "وقت البدء": 0,
- "نهاية الوقت": 0,
- "maxRetries": 0,
- "createdTime": 0,
- "disabledTime": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "وظائف": [
- {
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "scheduleId": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 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 | خيط قائمة منفصلة بفاصلة منقوطة لمعلمات الشرارة التي سيتم تطبيقها على وظيفة Spark. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| cron | خيط Cron expression to be applied for the schedule |
| أرجس | خيط قائمة منفصلة بفاصلة منقوطة من وسيطات الشرارة التي سيتم تطبيقها على وظيفة Spark. |
| فئة الوظيفة | خيط |
| متطلبات py | خيط قائمة منفصلة بفاصلة منقوطة لمتطلبات python. يجب فصل اسم الحزمة وإصدارها (إذا تم تقديمه) بعلامة مساواة مزدوجة. |
| 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": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": { },
- "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "الدولة": "سلسلة",
- "jobClass": "سلسلة",
- "args": [
- "سلسلة"
], - "وقت البدء": 0,
- "نهاية الوقت": 0,
- "maxRetries": 0,
- "createdTime": 0,
- "disabledTime": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "وظائف": [
- {
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "scheduleId": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 0,
- "وقت البدء": 0,
- "نهاية الوقت": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}
]
}إرجاع صفحة من الوظائف الموجودة
استفسار البارامترات
| أنواع الوظائف | مجموعة من سلاسل (نوع الوظيفة) العناصر تعداد: "أعزب" "تفاعلي" "شل" قائمة أنواع الوظائف المراد التقدم للتصفية |
| وظائف الدول | مجموعة من سلاسل (jobState) افتراضي: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" العناصر تعداد: "تم التقديم" "البدء" "جاهز" "مشغول" "فشل" "انتهى" "CANCELED" "غير معروف" قائمة حالات الوظيفة التي يجب التقدم بطلب للحصول على الفلترة |
| clusterNames | مجموعة من سلاسل قائمة أسماء نظام المجموعة المراد تطبيقها على التصفية |
| العلامات | خيط قائمة مفصولة بفاصلة منقوطة من العلامات للتقدم بطلب للتصفية. النمط: key1 = value1 ؛ المفتاح 2 = القيمة 2 |
| بحث | خيط الكلمة التي يجب التقدم بطلب للتصفية |
| صفحة | العدد الصحيح افتراضي: 0 عدد الصفحات المراد إرجاعها |
| حجم | العدد الصحيح افتراضي: 10 حجم الصفحة المراد إرجاعها |
| صنف | مجموعة من سلاسل مثل: فرز = اسم ، ASC قواعد الفرز التي سيتم تطبيقها لتعريف ترتيب ترحيل الصفحات |
الاستجابات
عينات الاستجابة
- 200
{- "الصفحة": {
- "رقم": 0,
- "الحجم": 0,
- "الإزاحة": 0,
- "صفحة": صحيح
}, - "فرز": [
- "سلسلة"
], - "totalElements": 0,
- "إجمالي الصفحات": 0,
- "أولا": صحيح,
- "الأخير": صحيح,
- "فارغ": صحيح,
- "المحتوى": [
- {
- "معرف العمل": "سلسلة",
- "معرف المجموعة": "سلسلة",
- "scheduleId": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 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": "سلسلة",
- "اسم الوظيفة": "سلسلة",
- "نوع الوظيفة": "سلسلة",
- "العلامات": "سلسلة",
- "اللغة": "سلسلة",
- "jobClass": "سلسلة",
- "clusterName": "سلسلة",
- "jobConfig": "سلسلة",
- "args": [
- "سلسلة"
], - "متطلبات py": "سلسلة",
- "packages": "سلسلة",
- "appId": "سلسلة",
- "الدولة": "سلسلة",
- "خطأ": "سلسلة",
- "وقت الإرسال": 0,
- "وقت البدء": 0,
- "نهاية الوقت": 0,
- "maxRetries": 0,
- "attempt": 0,
- "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}
}إرجاع السجلات لجميع موارد الوظائف
مسار البارامترات
| معرف الوظيفة مطلوب | خيط المعرف الفريد للوظيفة |
استفسار البارامترات
| logSize | العدد الصحيح <int64> افتراضي: 100 الحد الأقصى لعدد أسطر السجل المراد إرجاعها. يتم تعيين الحد في واجهة برمجة التطبيقات على 25000 سطر ، يمكنك تغييره عن طريق تعيين المعلمة ilum.api.job.logs.maxLines في ملف التكوين الخاص ب ilum-core |
| من | العدد الصحيح <int64> افتراضي: 0 الإزاحة من بداية السجل |
الاستجابات
عينات الاستجابة
- 200
- 404
[- {
- "الاسم": "سلسلة",
- "النوع": "سلسلة",
- "دور": "سلسلة",
- "الدولة": "سلسلة",
- "من": 0,
- "حجم السجل": 0,
- "اسم الملف": "سلسلة",
- "سجل": [
- "سلسلة"
]
}
]إرسال وظيفة Spark واحدة
طلب مخطط الجسم: بيانات متعددة الأجزاء / النماذجمطلوب
| اسم مطلوب | خيط |
| العلامات | خيط افتراضي: "المفتاح = القيمة. المفتاح 2 = القيمة 2 " قائمة علامات مفصولة بفاصلة منقوطة. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| اللغة | خيط افتراضي: "سكالا" تعداد: "سكالا" "بايثون" |
| clusterName مطلوب | خيط افتراضي: "افتراضي" |
| فئة الوظيفة | خيط |
| الجرار | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| الملفات | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| pyFiles | مجموعة من سلاسل <ثنائي> [ العناصر <ثنائي > ] |
| jobConfig | خيط افتراضي: "spark.key = القيمة. spark.key2 = القيمة 2 " قائمة منفصلة بفاصلة منقوطة لمعلمات الشرارة التي سيتم تطبيقها على وظيفة Spark. يجب فصل مفتاح المعلمة والقيمة بعلامة مساواة. |
| متطلبات py | خيط قائمة منفصلة بفاصلة منقوطة لمتطلبات python. يجب فصل اسم الحزمة وإصدارها (إذا تم تقديمه) بعلامة مساواة مزدوجة. |
| packages | خيط Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version. |
| أرجس | خيط قائمة منفصلة بفاصلة منقوطة من وسيطات الشرارة التي سيتم تطبيقها على وظيفة Spark. |
| 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
{- "معرف العمل": "سلسلة"
}إرجاع دفق تغييرات وظيفة Spark
استفسار البارامترات
| معرفات الوظائف | مجموعة من سلاسل قائمة معرفات الوظائف المراد التقدم للتصفية |
| معرفات المجموعة | مجموعة من سلاسل قائمة معرفات المجموعة التي يجب التقدم بطلب للتصفية |
| clusterNames | مجموعة من سلاسل قائمة أسماء نظام المجموعة المراد تطبيقها على التصفية |
| العلامات | خيط قائمة مفصولة بفاصلة منقوطة من العلامات للتقدم بطلب للتصفية. النمط: key1 = value1 ؛ المفتاح 2 = القيمة 2 |
الاستجابات
إنشاء تعريف نظام المجموعة
طلب مخطط الجسم: التطبيق / JSONمطلوب
| اسم مطلوب | خيط |
| وصف | خيط |
كائن | |
| sparkStorage | خيط افتراضي: "S3" |
| metastoreName | خيط |
كائن (memorySettingsCreation) | |
| defaultApplicationConfig | خيط |
| نوع مطلوب | خيط افتراضي: "K8S" |
| عنوان URL مطلوب | خيط |
| caCert | خيط |
| clientCert | خيط |
| مفتاح العميل | خيط |
| clientKeyAlgorithm | خيط |
| clientKeyPassphrase | خيط |
| اسم المستخدم | خيط |
| شعار | خيط |
كائن (clusterResourceQuota) | |
كائن (clusterLimitRange) |
الاستجابات
طلب عينات
- حموله
{- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "المخازن": {
- "خاصية 1": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}, - "خاصية 2": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}
}, - "سباركتوريج": "S3",
- "metastoreName": "سلسلة",
- "memorySettings": {
- "executors": "سلسلة",
- "driverCores": "سلسلة",
- "executorCores": "سلسلة",
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": "خطأ",
- "initialExecutors": "سلسلة",
- "minExecutors": "سلسلة",
- "maxExecutors": "سلسلة"
}, - "defaultApplicationConfig": "سلسلة",
- "النوع": "K8S",
- "عنوان URL": "سلسلة",
- "شهادة السيرت": "سلسلة",
- "clientCert": "سلسلة",
- "مفتاح العميل": "سلسلة",
- "clientKeyAlgorithm": "سلسلة",
- "clientKeyPassphrase": "سلسلة",
- "اسم المستخدم": "سلسلة",
- "كلمة المرور": "سلسلة",
- "resourceQuota": {
- "limitsPod": "سلسلة",
- "limitsCpu": "سلسلة",
- "limitsMemory": "سلسلة",
- "requestsCpu": "سلسلة",
- "requestsMemory": "سلسلة"
}, - "limitRange": {
- "cpuLimitRange": {
- "defaultLimit": "سلسلة",
- "defaultRequest": "سلسلة",
- "minRequest": "سلسلة",
- "maxLimit": "سلسلة",
- "maxLimitRequestRatio": "سلسلة"
}, - "memoryLimitRange": {
- "defaultLimit": "سلسلة",
- "defaultRequest": "سلسلة",
- "minRequest": "سلسلة",
- "maxLimit": "سلسلة",
- "maxLimitRequestRatio": "سلسلة"
}
}
}عينات الاستجابة
- 200
- 402
- 409
{- "clusterId": "سلسلة"
}إرجاع صفحة من المجموعات الموجودة
استفسار البارامترات
| بحث | خيط الكلمة التي يجب التقدم بطلب للتصفية |
| صفحة | العدد الصحيح افتراضي: 0 عدد الصفحات المراد إرجاعها |
| حجم | العدد الصحيح افتراضي: 10 حجم الصفحة المراد إرجاعها |
| صنف | مجموعة من سلاسل مثل: فرز = اسم ، ASC قواعد الفرز التي سيتم تطبيقها لتعريف ترتيب ترحيل الصفحات |
الاستجابات
عينات الاستجابة
- 200
{- "الصفحة": {
- "رقم": 0,
- "الحجم": 0,
- "الإزاحة": 0,
- "صفحة": صحيح
}, - "فرز": [
- "سلسلة"
], - "totalElements": 0,
- "إجمالي الصفحات": 0,
- "أولا": صحيح,
- "الأخير": صحيح,
- "فارغ": صحيح,
- "المحتوى": [
- {
- "المعرف": "سلسلة",
- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "سبارك ماستر": "سلسلة",
- "وضع شرارة الانتشار": "سلسلة",
- "سباركتوريج": "سلسلة",
- "metastoreName": "سلسلة",
- "المخازن": {
- "خاصية 1": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}, - "خاصية 2": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}
}, - "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "defaultApplicationConfig": "سلسلة",
- "النوع": "K8S",
- "عنوان URL": "سلسلة",
- "شهادة السيرت": "سلسلة",
- "clientCert": "سلسلة",
- "مفتاح العميل": "سلسلة",
- "clientKeyAlgorithm": "سلسلة",
- "clientKeyPassphrase": "سلسلة",
- "اسم المستخدم": "سلسلة",
- "كلمة المرور": "سلسلة",
- "resourceQuota": {
- "limitsPod": "سلسلة",
- "limitsCpu": "سلسلة",
- "limitsMemory": "سلسلة",
- "requestsCpu": "سلسلة",
- "requestsMemory": "سلسلة"
}, - "limitRange": {
- "cpuLimitRange": {
- "defaultLimit": "سلسلة",
- "defaultRequest": "سلسلة",
- "minRequest": "سلسلة",
- "maxLimit": "سلسلة",
- "maxLimitRequestRatio": "سلسلة"
}, - "memoryLimitRange": {
- "defaultLimit": "سلسلة",
- "defaultRequest": "سلسلة",
- "minRequest": "سلسلة",
- "maxLimit": "سلسلة",
- "maxLimitRequestRatio": "سلسلة"
}
}
}
]
}إرجاع نظام مجموعة تم العثور عليها بواسطة المعرف الخاص بها
مسار البارامترات
| clusterId مطلوب | خيط المعرف الفريد لنظام المجموعة |
الاستجابات
عينات الاستجابة
- 200
- 404
{- "المعرف": "سلسلة",
- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "سبارك ماستر": "سلسلة",
- "وضع شرارة الانتشار": "سلسلة",
- "سباركتوريج": "سلسلة",
- "metastoreName": "سلسلة",
- "المخازن": {
- "خاصية 1": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}, - "خاصية 2": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}
}, - "memorySettings": {
- "executors": 0,
- "driverCores": 0,
- "executorCores": 0,
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": صحيح,
- "initialExecutors": 0,
- "minExecutors": 0,
- "maxExecutors": 0
}, - "defaultApplicationConfig": "سلسلة",
- "النوع": "K8S",
- "عنوان URL": "سلسلة",
- "شهادة السيرت": "سلسلة",
- "clientCert": "سلسلة",
- "مفتاح العميل": "سلسلة",
- "clientKeyAlgorithm": "سلسلة",
- "clientKeyPassphrase": "سلسلة",
- "اسم المستخدم": "سلسلة",
- "كلمة المرور": "سلسلة",
- "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
مسار البارامترات
| clusterId مطلوب | خيط المعرف الفريد لنظام المجموعة |
طلب مخطط الجسم: التطبيق / JSONمطلوب
| اسم مطلوب | خيط |
| وصف | خيط |
كائن | |
| sparkStorage | خيط افتراضي: "S3" |
| metastoreName | خيط |
كائن (memorySettingsCreation) | |
| defaultApplicationConfig | خيط |
| نوع مطلوب | خيط افتراضي: "K8S" |
| عنوان URL مطلوب | خيط |
| caCert | خيط |
| clientCert | خيط |
| مفتاح العميل | خيط |
| clientKeyAlgorithm | خيط |
| clientKeyPassphrase | خيط |
| اسم المستخدم | خيط |
| شعار | خيط |
كائن (clusterResourceQuota) | |
كائن (clusterLimitRange) |
الاستجابات
طلب عينات
- حموله
{- "الاسم": "سلسلة",
- "الوصف": "سلسلة",
- "المخازن": {
- "خاصية 1": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}, - "خاصية 2": {
- "سبارك باكلت": "سلسلة",
- "dataBucket": "سلسلة",
- "extraBuckets": [
- "سلسلة"
], - "النوع": "S3",
- "نقطة النهاية": "سلسلة",
- "region": "us-east-1",
- "مفتاح الوصول": "سلسلة",
- "المفتاح السري": "سلسلة"
}
}, - "سباركتوريج": "S3",
- "metastoreName": "سلسلة",
- "memorySettings": {
- "executors": "سلسلة",
- "driverCores": "سلسلة",
- "executorCores": "سلسلة",
- "driverMemory": "سلسلة",
- "executorMemory": "سلسلة",
- "dynamicAllocation": "خطأ",
- "initialExecutors": "سلسلة",
- "minExecutors": "سلسلة",
- "maxExecutors": "سلسلة"
}, - "defaultApplicationConfig": "سلسلة",
- "النوع": "K8S",
- "عنوان URL": "سلسلة",
- "شهادة السيرت": "سلسلة",
- "clientCert": "سلسلة",
- "مفتاح العميل": "سلسلة",
- "clientKeyAlgorithm": "سلسلة",
- "clientKeyPassphrase": "سلسلة",
- "اسم المستخدم": "سلسلة",
- "كلمة المرور": "سلسلة",
- "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
مسار البارامترات
| clusterId مطلوب | خيط المعرف الفريد لنظام المجموعة |
طلب مخطط الجسم: التطبيق / 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 مطلوب | خيط |
| clusterId | خيط |
| maxRows | العدد الصحيح <int64> افتراضي: 1000 |
| engine | خيط (sqlEngineType) افتراضي: "SPARK_SQL" تعداد: "SPARK_SQL" "TRINO" |
الاستجابات
طلب عينات
- حموله
{- "statement": "سلسلة",
- "clusterId": "سلسلة",
- "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,
- "صفحة": صحيح
}, - "فرز": [
- "سلسلة"
], - "totalElements": 0,
- "إجمالي الصفحات": 0,
- "أولا": صحيح,
- "الأخير": صحيح,
- "فارغ": صحيح,
- "المحتوى": [
- {
- "المعرف": "سلسلة",
- "الاسم": "سلسلة",
- "statement": "سلسلة",
- "engine": "SPARK_SQL",
- "maxRows": 0
}
]
}Saves an SQL statement
طلب مخطط الجسم: التطبيق / JSONمطلوب
| اسم مطلوب | خيط |
| statement مطلوب | خيط |
| engine | خيط (sqlEngineType) افتراضي: "SPARK_SQL" تعداد: "SPARK_SQL" "TRINO" |
| maxRows | العدد الصحيح <int64> |
الاستجابات
طلب عينات
- حموله
{- "الاسم": "سلسلة",
- "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 | العدد الصحيح <int64> |
الاستجابات
طلب عينات
- حموله
{- "الاسم": "سلسلة",
- "statement": "سلسلة",
- "engine": "SPARK_SQL",
- "maxRows": 0
}عينات الاستجابة
- 402
- 404
{- "رسالة": "سلسلة"
}Returns a page of SQL notebooks
استفسار البارامترات
| صفحة | العدد الصحيح افتراضي: 0 عدد الصفحات المراد إرجاعها |
| حجم | العدد الصحيح افتراضي: 10 حجم الصفحة المراد إرجاعها |
| صنف | مجموعة من سلاسل مثل: فرز = اسم ، ASC قواعد الفرز التي سيتم تطبيقها لتعريف ترتيب ترحيل الصفحات |
| بحث | خيط الكلمة التي يجب التقدم بطلب للتصفية |
الاستجابات
عينات الاستجابة
- 200
- 409
{- "الصفحة": {
- "رقم": 0,
- "الحجم": 0,
- "الإزاحة": 0,
- "صفحة": صحيح
}, - "فرز": [
- "سلسلة"
], - "totalElements": 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
{- "رسالة": "سلسلة"
}