من المقطع المقدم ، استخراج المستهلكين المدعومين لتدفق الشرارة. افصل بينهما بفترة.
Context:يستخدم Spark Streaming قدرة جدولة Spark Core السريعة لإجراء تحليلات البث. إنه يأخذ البيانات في مجموعات صغيرة ويقوم بتحويلات RDD على هذه المجموعات الصغيرة من البيانات. يتيح هذا التصميم استخدام نفس مجموعة رمز التطبيقات المكتوبة لتحليل الدفعات في تحليلات التدفق ، وبالتالي تسهيل تنفيذ بنية lambda بسهولة. ومع ذلك، يأتي هذا الراحة مع عقوبة من فترة التأخير تساوي مدة الدفعة الصغيرة. وتشمل محركات البيانات المتدفقة الأخرى التي تعالج الحدث بحدث بدلاً من الدفعات المصغرة Storm ومكون تدفق Flink. يحتوي Spark Streaming على دعم مدمج للاستهلاك من منافذ Kafka و Flume و Twitter و ZeroMQ و Kinesis و TCP / IP.  في سبارك 2.x ، يتم توفير تقنية منفصلة تستند إلى مجموعات البيانات ، تسمى البث المنظم ، والتي لديها واجهة أعلى مستوى لدعم البث.  يمكن نشر سبارك في مركز بيانات تقليدي على الموقع وكذلك في السحابة.
كافكا، فلوم، تويتر، زيرو إم كيو، كينيسيس، TCP/IP سوكات