Skip to content

Instantly share code, notes, and snippets.

@Arnonrgo

Arnonrgo/gist:b24b41a1576d8f61ba12

Created September 14, 2014 11:21
Show Gist options
  • Save Arnonrgo/b24b41a1576d8f61ba12 to your computer and use it in GitHub Desktop.
Save Arnonrgo/b24b41a1576d8f61ba12 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.scala
ParquetOutputFormat.setWriteSupportClass(job,classOf[ProtoWriteSupport[Aggregate]])
ProtoParquetOutputFormat.setProtobufClass(job,classOf[Aggregate])
hourlyAggregates.saveAsNewAPIHadoopFile(outputDir,
classOf[Void],
classOf[Aggregate],
classOf[ParquetOutputFormat[Aggregate]],
job.getConfiguration)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment