scala — أسئلة مع إجابات

1 إجابة
أنا جديد في محور أزور أيوت. أنا أحاول أن أسحب الرسالة من محور أزور أيوت باستخدام شرارة التدفق. أحصل على خطأ عند تنفيذ التعليمات البرمجية وأتفهم أن هناك مشكلة في سلاسل الاتصال. هل هناك أي طريقة محددة للتحقق من صحة سلسلة الاتصال في شرارة وأيضا أخبرني التنسيق الذي حددته صحيح أم لا. رمز العينة الخاص ب...
apache-spark
spark-streaming
azure-iot-hub
azure-eventhub
26.07.2018, 09:18
1 إجابة
لدينا نقطتا نهاية (مكالمات خلفية) تعرضان أنواع بيانات مختلفة ولكنها ذات صلة XData و YData . إذا مثيل XData موجود بمعرف 1 ، ثم يجب أن يكون هناك مثيل لـ YData بنفس المعرف 1 . لقد أنشأنا أداة جلب لكل نوع بيانات xFetcher و yFetcher . يتم استخدام هذه الجلب بشكل منفصل في استعلام GraphQL الخاص بنا لجلب ا...
graphql
sangria
26.07.2018, 08:35
1 إجابة
لدي ملفان من الباركيه ، أحدهما يصف الملفات برقم inode ، وواحد يصف اسم inode و inode الأصلي ، أحتاج إلى إعادة بناء المسار الكامل من الملف الثاني. تم تسمية جدولي مع وصف inode idirs_table_read ويتم صياغتها على هذا النحو (هذا مثال كامل): iparent,iname,ichild 93767723,folder12,40715069 65688175,level4,...
apache-spark
recursion
parquet
11.07.2018, 13:17
1 إجابة
المهمة هي إنشاء عمود جديد مع اختلاف بين عدد السنوات مثل بيانات 2002 - بيانات 2001 إدخال: +----+-------------------+ |col1|col2 | +----+-------------------+ |2001 |10. | |2002 |15. | |2003 |19. | +----+-------------------+ انتاج: +----+---------...
dataframe
apache-spark
rdd
11.07.2018, 13:02
1 إجابة
أنا جديد على Scala وربما يكون من السهل حل هذه المشكلة ولكني أواجه صعوبة في فهم سبب وجود أخطاء في الترجمة. لذلك لدي فئات حالتي case class AggregationQuery ( startDate: String, endDate: String, aggregates: Aggregates, value: Value, options: Options ) case class Aggregates (aggregate: ...
spray-json
11.07.2018, 12:52
فوق
قائمة طعام