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 <[email protected]>
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.
>
