إرجاع صفحة من المجموعات الموجودة
استفسار البارامترات
| مجموعة الدول | مجموعة من سلاسل ( مجموعة الدولة ) العناصر تعداد : "نشط" "مؤرشف" قائمة حالات المجموعة التي ستتقدم بطلب للتصفية |
| مجموعة الأنواع | مجموعة من سلاسل ( مجموعةنوع ) العناصر تعداد : "وظيفة" "الرمز" قائمة أنواع المجموعات المراد التقدم بطلب للتصفية |
| وظائف الدول | مجموعة من سلاسل ( 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
{ - "المعرف" : "سلسلة"
} Returns an SQL notebook found by its id
مسار البارامترات
| sqlNotebookId مطلوب | خيط The unique identifier of an SQL notebook |
الاستجابات
عينات الاستجابة
- 200
- 404
{ - "المعرف" : "سلسلة" ,
- "الاسم" : "سلسلة" ,
- "statements": [
- {
- "المعرف" : "سلسلة" ,
- "اللغة" : "SQL",
- "code": "سلسلة"
}
]
} 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
{ - "رسالة" : "سلسلة"
}