Skip to content

Instantly share code, notes, and snippets.

@shrijitpillai
shrijitpillai / WordCountSpark.java
Created January 3, 2019 17:06
Apache Beam WordCount using Spark Runner
package org.wordcount;
import java.util.Arrays;
import java.util.List;
import org.apache.beam.runners.spark.SparkPipelineOptions;
import org.apache.beam.runners.spark.SparkPipelineResult;
import org.apache.beam.runners.spark.SparkRunner;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.io.TextIO;
package com.learning;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;
public class MeetingRooms {
static int getMinimumMeetingRooms(List<List<Integer>> meetings){