What's the correct way to use setCallSite to get the change to show up in the spark logs?
I have something like
class RichRDD (rdd : RDD[MyThing]) {
def mySpecialOperation() {
rdd.context.setCallSite("bubbles and candy!")
rdd.map(....)
val result = rdd.groupBy(....)
rdd.context.clearCallSite()
result
}
}
But when I use .mySpecialOperation "bubbles and candy!" doesn't seem to
show up anywhere in the logs. Is this not the right way to use
.setCallSite?
