يحتوي هذا المنشور على الخطوة الضرورية المطلوبة لإنشاء UDF في Apache Pig. يجب أن يوسع كل UDF وظيفة التصفية ويجب أن يحتوي على طريقة تسمى exec ، والتي تحتوي على Tuple. المنطق المطبق هنا هو أنه إذا كان Tuple فارغًا أو صفرًا ، فسوف يمنحك قيمة منطقية: True أو False. و 'IsofAge' للتحقق مما إذا كان العمر المعطى صحيحًا أم لا. يتم كتابة منطق الوظيفة المعرفة بواسطة المستخدم بأكواد Java ، حيث سيتم إنشاء ملف JAR ثم تصديره. يتم تسجيل ملف JAR لاحقًا. تم العثور على ملفات JAR هذه في ملفات مكتبة Apache Pig في وقت التحميل.
يمتد IsOfAge للفئة العامة FilterFunc { @تجاوز publicBoolean exec (Tuple tuple) رمياتIOException { إذا (tuple == null || tuple.size () == 0) { عودة كاذبة } محاولة{ كائن الكائن = tuple.get (0) إذا (الكائن == فارغ) { عودة كاذبة } inti = (عدد صحيح) كائن إذا (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { عائد صحيح } آخر { عودة كاذبة }} catch (ExecExceptione) { تم طرح استثناء (هـ) }}}كيفية استدعاء Pig UDF؟
بمجرد إنشاء UDF ، يجب استخدام الأمر التالي لتسجيل ملف JAR.
سجل myudf.jar X = عامل التصفية A حسب IsOfAge (العمر)
خطوات إنشاء UDF في Pig:
هناك العديد من الوظائف المحددة مسبقًا في Apache Pig. لدينا أيضًا ميزة إنشاء وظيفتنا الخاصة وهي الوظيفة المحددة بواسطة المستخدم (UDF). تمت كتابة Pig UDF بلغة Java وهذا يتطلب Pig Library لاستخدام الفئات المحددة مسبقًا. مكتبة Apache Pig خنزير 0.8.0-cdh3u0-core.jar يمكن تحميلها من الانترنت.
انقر هنا للحصول على خطوات إنشاء برنامج نصي Pig باستخدام UDF في وضع HDFS.
لديك سؤال لنا؟ أذكرها في قسم التعليقات وسنعاود الاتصال بك.
المنشورات ذات الصلة:
برنامج Apache Pig Script مع UDF في وضع HDFS
العوامل في Apache Pig: الجزء الأول - العوامل العلائقية
المشغلون في Apache Pig: الجزء 2 - عوامل التشخيص
تجاوز مقابل التحميل الزائد c ++