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
