@@ -0,0 +1,630 @@
+package com.jasongj.spark.writer;%0A%0Aimport com.jasongj.spark.model.Tuple;%0Aimport org.apache.hadoop.conf.Configuration;%0Aimport org.apache.hadoop.fs.Path;%0A%0Aimport java.io.DataOutputStream;%0A%0A/**%0A * Created by Jason Guo (jason.guo.vip@gmail.com)%0A */%0Apublic class ParquetWriter extends TupleWriter%7B%0A%0A    public ParquetWriter(DataOutputStream dataOutputStream, Configuration hadoopConfiguration, Path path) %7B%0A        super(dataOutputStream, hadoopConfiguration, path);%0A    %7D%0A%0A    @Override%0A    public void write(Tuple tuple) %7B%0A%0A    %7D%0A%0A    @Override%0A    public void close() %7B%0A%0A    %7D%0A%0A    public static void main(String%5B%5D args) %7B%0A%0A    %7D%0A%7D%0A

Add parquet writer