Arnonrgo

ParquetOutputFormat.setWriteSupportClass(job,classOf[ProtoWriteSupport[Aggregate]])
ProtoParquetOutputFormat.setProtobufClass(job,classOf[Aggregate])
hourlyAggregates.saveAsNewAPIHadoopFile(outputDir,
                                        classOf[Void],
                                        classOf[Aggregate],
                                        classOf[ParquetOutputFormat[Aggregate]],
                                        job.getConfiguration)

Arnonrgo

val data = sc.textFile("src/test/resources/*.csv")

val calls = data.map (Call(_)).cache()

val hourlyPairs = calls.map(c => (c.getHourly,c))
val weeklyPairs = calls.map(c => (c.getWeekly,c))

val groupedHourly = hourlyPairs.groupByKey()
val groupedWeekly = weeklyPairs.groupByKey()

Arnonrgo

  val tableName="testTable"
  val family = Bytes.toBytes("f")
  val qualifier=Bytes.toBytes("q")

  val hbaseTestUtil = new HBaseTestingUtility()
  val config = hbaseTestUtil.getConfiguration

  val tmpDir = File.createTempFile("logdir", "")
  tmpDir.delete()
  tmpDir.mkdir()

Arnonrgo

package com.yammer.metrics.jersey.tests.resources;

import com.yammer.metrics.annotation.ExceptionMetered;
import com.yammer.metrics.annotation.Metered;
import com.yammer.metrics.annotation.Timed;

import javax.ws.rs.*;
import javax.ws.rs.core.MediaType;
import java.io.IOException;