Class MapperRowCounter

Object
org.apache.spark.util.AccumulatorV2<Long,List<scala.Tuple2<Integer,Long>>>
org.apache.spark.sql.util.MapperRowCounter
All Implemented Interfaces:
Serializable

public class MapperRowCounter extends AccumulatorV2<Long,List<scala.Tuple2<Integer,Long>>>
An AccumulatorV2 counter for collecting a list of (mapper index, row count).

Since:
3.4.0
See Also: