org.apache.hadoop.hive.ql.io.parquet.write
Class ParquetRecordWriterWrapper
java.lang.Object
org.apache.hadoop.hive.ql.io.parquet.write.ParquetRecordWriterWrapper
- All Implemented Interfaces:
- FileSinkOperator.RecordWriter, org.apache.hadoop.mapred.RecordWriter<Void,org.apache.hadoop.io.ArrayWritable>
public class ParquetRecordWriterWrapper
- extends Object
- implements org.apache.hadoop.mapred.RecordWriter<Void,org.apache.hadoop.io.ArrayWritable>, FileSinkOperator.RecordWriter
Field Summary |
static org.apache.commons.logging.Log |
LOG
|
Constructor Summary |
ParquetRecordWriterWrapper(org.apache.hadoop.mapreduce.OutputFormat<Void,org.apache.hadoop.io.ArrayWritable> realOutputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
String name,
org.apache.hadoop.util.Progressable progress)
|
Method Summary |
void |
close(boolean abort)
|
void |
close(org.apache.hadoop.mapred.Reporter reporter)
|
void |
write(Void key,
org.apache.hadoop.io.ArrayWritable value)
|
void |
write(org.apache.hadoop.io.Writable w)
|
LOG
public static final org.apache.commons.logging.Log LOG
ParquetRecordWriterWrapper
public ParquetRecordWriterWrapper(org.apache.hadoop.mapreduce.OutputFormat<Void,org.apache.hadoop.io.ArrayWritable> realOutputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
String name,
org.apache.hadoop.util.Progressable progress)
throws IOException
- Throws:
IOException
close
public void close(org.apache.hadoop.mapred.Reporter reporter)
throws IOException
- Specified by:
close
in interface org.apache.hadoop.mapred.RecordWriter<Void,org.apache.hadoop.io.ArrayWritable>
- Throws:
IOException
write
public void write(Void key,
org.apache.hadoop.io.ArrayWritable value)
throws IOException
- Specified by:
write
in interface org.apache.hadoop.mapred.RecordWriter<Void,org.apache.hadoop.io.ArrayWritable>
- Throws:
IOException
close
public void close(boolean abort)
throws IOException
- Specified by:
close
in interface FileSinkOperator.RecordWriter
- Throws:
IOException
write
public void write(org.apache.hadoop.io.Writable w)
throws IOException
- Specified by:
write
in interface FileSinkOperator.RecordWriter
- Throws:
IOException
Copyright © 2014 The Apache Software Foundation. All rights reserved.