File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
src/main/scala/com/oreilly/learningsparkexamples/scala Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -11,15 +11,14 @@ import org.apache.spark.SparkContext._
1111import org .apache .hadoop .io .Text
1212import com .twitter .elephantbird .mapreduce .io .ProtobufWritable
1313import com .twitter .elephantbird .mapreduce .output .LzoProtobufBlockOutputFormat
14- import org .apache .hadoop .mapreduce . Job
14+ import org .apache .hadoop .conf . Configuration
1515
1616object BasicSaveProtoBuf {
1717 def main (args : Array [String ]) {
1818 val master = args(0 )
1919 val outputFile = args(1 )
2020 val sc = new SparkContext (master, " BasicSaveProtoBuf" , System .getenv(" SPARK_HOME" ))
21- val job = new Job ()
22- val conf = job.getConfiguration
21+ val conf = new Configuration ()
2322 LzoProtobufBlockOutputFormat .setClassConf(classOf [Places .Venue ], conf);
2423 val dnaLounge = Places .Venue .newBuilder()
2524 dnaLounge.setId(1 );
You can’t perform that action at this time.
0 commit comments