From 33ee00ffc0182b7774c3db0e849316598c505501 Mon Sep 17 00:00:00 2001 From: Liwei Lin Date: Wed, 10 Aug 2016 14:11:11 +0800 Subject: [PATCH] =?UTF-8?q?ConcurrentJobsDemo=20=E4=B8=AD=20MyReceiver=20?= =?UTF-8?q?=E6=9E=84=E9=80=A0=E5=87=BD=E6=95=B0=E5=8E=BB=E6=8E=89=20()?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../2.1 JobScheduler, Job, JobSet \350\257\246\350\247\243.md" | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git "a/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/2.1 JobScheduler, Job, JobSet \350\257\246\350\247\243.md" "b/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/2.1 JobScheduler, Job, JobSet \350\257\246\350\247\243.md" index d920146..7837caf 100644 --- "a/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/2.1 JobScheduler, Job, JobSet \350\257\246\350\247\243.md" +++ "b/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/2.1 JobScheduler, Job, JobSet \350\257\246\350\247\243.md" @@ -242,7 +242,7 @@ object ConcurrentJobsDemo { ssc.awaitTermination() } - class MyReceiver() extends Receiver[String](StorageLevel.MEMORY_ONLY) { + class MyReceiver extends Receiver[String](StorageLevel.MEMORY_ONLY) { override def onStart() { // invoke store("str") every 100ms