Main.java

public static void main(String[] args) {
    SparkConf sparkConf = new SparkConf()
            .setMaster("local[*]")
            .setAppName("Example01");
    JavaSparkContext sc = new JavaSparkContext(sparkConf);
    sc.parallelize(IntStream.range(1, 100).boxed().collect(Collectors.toList())).map(x -> {
        return (x % 15 == 0) ? "FizzBuzz"
             : (x % 5 == 0) ? "Fizz"
             : (x % 3 == 0) ? "Buzz"
             : x.toString();
    }).foreach(x -> System.out.println(x));
    sc.stop();
}