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()