[spark] ¿Usar Scala para escribir un programa para contar el número de ayb en el archivo en la máquina virtual?

El siguiente es un programa implementado en una máquina virtual que usa Scala y Spark para calcular el número de a y b en un archivo:

``scala

import org.apache.spark. _

importar org.apache.spark.SparkContext ._

importar org.apache.log4j._

objeto FileCharacterCount {

def main (args: Array[String]) {

Logger.getLogger("org") .setLevel(Level.ERROR)

// Inicializar SparkContext

val conf = new SparkConf().setAppName("FileCharacterCount").setMaster("local")

val sc = new SparkContext(conf)

// Lee el archivo y compárelo Procesar

val file = sc.textFile("ruta/a/su/archivo")

val aCount = file.flatMap(line =gt)