Currently SetAccumulator (which extends AccumulatorV2[T,java.util.Set[T]]) is a 
nested class of org.apache.spark.sql.execution.debug.DebugExec. I wonder why 
this quite useful class is buried there, in spark-sql, and not presented in 
org.apache.spark.util of spark-core.


---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscr...@spark.apache.org

Reply via email to