sparkSession = SparkSession.getOrCreate() inputDataset = sparkSession.read(new DataSourceV2(BeamRead)) splitDataset = inputDataset.flatmap(BeamPardo) countDataset = splitDataset.agg(BeamCombiner) formatDataset = countDataset.flatmap(BeamPardo) outputDataset = formatDataset.flatmap(BeamPardo) outputDataset.foreach()