val sem = 0 sc.addSparkListener(new SparkListener { override def onTaskStart(taskStart: SparkListenerTaskStart) { sem +=1 }
}) sc = spark context Mayur Rustagi Ph: +1 (760) 203 3257 http://www.sigmoidanalytics.com @mayur_rustagi <https://twitter.com/mayur_rustagi> On Wed, Jul 9, 2014 at 4:34 AM, abhiguruvayya <sharath.abhis...@gmail.com> wrote: > Hello Mayur, > > How can I implement these methods mentioned below. Do u you have any clue > on > this pls et me know. > > > public void onJobStart(SparkListenerJobStart arg0) { > } > > @Override > public void onStageCompleted(SparkListenerStageCompleted arg0) { > } > > @Override > public void onStageSubmitted(SparkListenerStageSubmitted arg0) { > > } > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Spark-job-tracker-tp8367p9104.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. >