gistfile1.txt

    snsc.sql("create table adImpressions(times_tamp timestamp, publisher string, " +
      "advertiser string, website string, geo string, bid double, cookie string) " +
      "using column options ( buckets '29', persistent 'asynchronous')")
 
    snsc.sql("CREATE SAMPLE TABLE sampledAdImpressions" +
  	" OPTIONS(qcs 'geo,publisher', fraction '0.02', strataReservoirSize '50', baseTable 'adImpressions')")
 
    snsc.getSchemaDStream("adImpressionStream").foreachDataFrame( df => {
    	df.write.insertInto("adImpressions")
        df.write.insertInto("sampledAdImpressions")
  	})