@Test public void test() throws Exception { DataStreamLoaderExample.main(null); }
public static void main(String[] args) throws Exception { SparkConf conf = new SparkConf().setAppName("SLink!").setMaster("local"); SparkContext sc = new SparkContext(conf); SQLContext sqlContext = new SQLContext(sc); String path ="datasets/simulated/WI_samples.json"; DataSpark dataSpark = DataSparkLoader.open(sqlContext, path); dataSpark.collectDataStream() .forEach( dataInstance -> System.out.println(dataInstance) ); }
DataStreamLoaderExample { public static void main(String[] args) throws Exception { SparkConf conf = new SparkConf().setAppName("SLink!").setMaster("local"); SparkContext sc = new SparkContext(conf); SQLContext sqlContext = new SQLContext(sc); String path ="datasets/simulated/WI_samples.json"; DataSpark dataSpark = DataSparkLoader.open(sqlContext, path); dataSpark.collectDataStream() .forEach( dataInstance -> System.out.println(dataInstance) ); } }
DataStreamLoaderExample { public static void main(String[] args) throws Exception { SparkConf conf = new SparkConf().setAppName("SLink!").setMaster("local"); SparkContext sc = new SparkContext(conf); SQLContext sqlContext = new SQLContext(sc); String path ="datasets/simulated/WI_samples.json"; DataSpark dataSpark = DataSparkLoader.open(sqlContext, path); dataSpark.collectDataStream() .forEach( dataInstance -> System.out.println(dataInstance) ); }  }
DataStreamLoaderExample { public static void main(String[] args) throws Exception { SparkConf conf = new SparkConf().setAppName("SLink!").setMaster("local"); SparkContext sc = new SparkContext(conf); SQLContext sqlContext = new SQLContext(sc); String path ="datasets/simulated/WI_samples.json"; DataSpark dataSpark = DataSparkLoader.open(sqlContext, path); dataSpark.collectDataStream() .forEach( dataInstance -> System.out.println(dataInstance) ); }  static void main(String[] args); }
DataStreamLoaderExample { public static void main(String[] args) throws Exception { SparkConf conf = new SparkConf().setAppName("SLink!").setMaster("local"); SparkContext sc = new SparkContext(conf); SQLContext sqlContext = new SQLContext(sc); String path ="datasets/simulated/WI_samples.json"; DataSpark dataSpark = DataSparkLoader.open(sqlContext, path); dataSpark.collectDataStream() .forEach( dataInstance -> System.out.println(dataInstance) ); }  static void main(String[] args);  }