من السهل جدولة هو البيانات الموزعة سير العمل مهمة نظام الجدولة، أساسا لحل تبعيات بيانات التنمية ETL معقدة، ولكن لا يمكن رصد مباشر على الحالة الصحية للمهام وقضايا أخرى. من السهل جدولة لDAG بطريقة تدفق العمل تجميعها، ويمكن تشغيلها في الوقت الحقيقي رصد المهام، بينما تدعم إعادة المحاولة، تفشل في استرداد، وقفة وقتل المهام والعمليات الأخرى من العقدة المحددة.

تصميم الميزات:  والتصور DAG نظام جدولة المهام سير العمل الموزعة وقابلة للتطوير. عناوين واعتماد البيانات المعقدة تجهيز الإجراءات، بحيث نظام خارج الجدولة في معالجة البيانات التدفق. أهدافها الرئيسية هي كما يلي:

• من طريق DAG وربط تبعيات المهام وفقا للمهمة إدارة الدولة يمكن رصد المهام التصور في الوقت الحقيقي
• يدعم أنواع مختلفة من المهام: شل، MR، سبارك، SQL (MySQL، الإنترنت، خلية، sparksql)، بيثون، Sub_Process، الداخلي، الخ
• سير العمل دعم جدول منتظم، وجدولة التابعة، دليل جدولة، اليدوي وقفة / إيقاف / الانتعاش، بينما تدعم فشل المحاولة / التنبيه والانتعاش الفشل، وعملية قتل المهام من العقدة المحددة
• دعم سير العمل الأولويات والمهام ذات الأولوية الفشل والمهام ومهمة مهلة الانذار / فشل
• سير العمل دعم المعلمات العالمية وعقدة المعلمات المخصصة إعدادات
• موارد الدعم تحميل الملفات على الانترنت / تنزيل، وإدارة، وتقديم الدعم لإنشاء المستندات عبر الإنترنت، تحرير،
• دعم دخول العمل على الانترنت لعرض والتمرير، على شبكة الإنترنت تحميل السجلات، الخ
• تنفيذ مجموعة HA، حققت مجموعات ماستر العمال والكتلة إلى المركز من قبل حارس الحديقة
• ودعم الرأي للتحميل وحدة المعالجة المركزية، ماجستير / عامل، والذاكرة، وحدة المعالجة المركزية على الانترنت
• دعم تاريخ العملية شجرة سير العمل / مخطط جانت البرامج والإحصاءات دولة مهمة الدعم، ووضع العملية الإحصائية
• دعم مكمل
• دعم متعدد الإيجار
• الدعم الدولي
• وهناك مزيد من الانتظار لشركاء لاستكشاف

مقارنة مع نظام الجدولة مماثل

أجزاء قطة من نظام

مهمة تستند SHELL-

واستنادا إلى غزل حساب (انظر MapReduceTask)

• الحاجة cn.escheduler.server.worker.task  تحت يبرد  إنشاء فئة مهمة مخصصة (أيضا أن تكون مسجلة في المقابلة نوع المهمة TaskType)
• الحاجة إلى وراثة cn.escheduler.server.worker.task  تحت AbstractYarnTask
• جدولة منشئ AbstractYarnTask  منشئ
• وراثة AbstractParameters  الكيانات المعلمة المهام مخصصة
• إعادة كتابة AbstractTask  من الحرف الأول  المنهج التحليلي المعلمات مهمة مخصصة
• إعادة كتابة buildCommand  قيادة حزمة

وبناء على حساب عدم غزل (انظر ShellTask)

• الحاجة cn.escheduler.server.worker.task  تحت يبرد  إنشاء مهمة مخصصة
• الحاجة إلى وراثة cn.escheduler.server.worker.task  تحت AbstractTask
• إنشاء مثيل منشئ ShellCommandExecutor

الجمهور ShellTask (TaskProps الدعائم، والمسجل مسجل) { سوبر (الدعائم، مسجل)؛ this.taskDir = props.getTaskDir ()؛ this.processTask = ShellCommandExecutor الجديد (هذا :: logHandle، props.getTaskDir ()، props.getTaskAppId () props.getTenantCode ()، props.getEnvFile ()، props.getTaskStartTime () props.getTaskTimeout ()، مسجل)؛ this.processDao = DaoFactory.getDaoInstance (ProcessDao.class)؛ }

• مهمة مخصصة واردة TaskProps والعرف مسجل ، TaskProps بتغليف سجل مخصصة المعلومات المهمة، المسجل الاستغناء
• وراثة AbstractParameters  الكيانات المعلمة المهام مخصصة
• إعادة كتابة AbstractTask  من الحرف الأول  المنهج التحليلي الكيانات المعلمة المهام مخصصة
• إعادة كتابة مقبض  طريقة، دعوة ShellCommandExecutor  من جولة  طريقة، الوسيطة الأولى تملك قيادة والحجة الثانية لProcessDao، تعيين المقابلة exitStatusCode

وبناء على المهام غير SHELL (انظر SqlTask)

• الحاجة cn.escheduler.server.worker.task  تحت يبرد  إنشاء مهمة مخصصة
• الحاجة إلى وراثة cn.escheduler.server.worker.task  تحت AbstractTask
• وراثة AbstractParameters  الكيانات المعلمة المهام مخصصة
• منشئ أو الكتابة AbstractTask  من الحرف الأول  طريقة، تحليل مخصصة الكيانات المعلمة مهمة
• إعادة كتابة مقبض  طريقة منطق الأعمال ومجموعة المقابلة exitStatusCode