spark涓璵ap鍑芥暟(Spark dataset.mapPartitions debug到mapPartitions的函数体)

Dataset dataset = null;
StructType schema = dataset.schema();
Dataset rowDataset = dataset.mapPartitions(
        new MapPartitionsFunction() {
            @Override
            public Iterator call(Iterator iterator) throws Exception {
                List list = new ArrayList<>();
                while (iterator.hasNext()) {
                    Row next = iterator.next();
                }
                return null;
            }
        }
        , RowEncoder.apply(schema));

如上代码，如果debug需要定位到new MapPartitionsFunction() 的call方法，需要如下操作：
1、定位到mapPartitions所在行

2、点击左下角debug的Step Into按钮

此时代码会出现如下情景：

3、这时点击call的函数体，此时就可进入call的函数里进行debug