Package | Description |
---|---|
org.apache.hadoop.hive.ql.io.parquet | |
org.apache.hadoop.hive.ql.io.parquet.write |
Modifier and Type | Field and Description |
---|---|
protected org.apache.parquet.hadoop.ParquetOutputFormat<ParquetHiveRecord> |
MapredParquetOutputFormat.realOutputFormat |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,ParquetHiveRecord> |
MapredParquetOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable progress) |
Modifier and Type | Method and Description |
---|---|
protected ParquetRecordWriterWrapper |
MapredParquetOutputFormat.getParquerRecordWriterWrapper(org.apache.parquet.hadoop.ParquetOutputFormat<ParquetHiveRecord> realOutputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
String finalOutPath,
org.apache.hadoop.util.Progressable progress,
Properties tableProperties) |
Constructor and Description |
---|
MapredParquetOutputFormat(org.apache.hadoop.mapreduce.OutputFormat<Void,ParquetHiveRecord> mapreduceOutputFormat) |
Modifier and Type | Method and Description |
---|---|
void |
ParquetRecordWriterWrapper.write(org.apache.hadoop.io.NullWritable key,
ParquetHiveRecord value) |
void |
DataWritableWriteSupport.write(ParquetHiveRecord record) |
void |
DataWritableWriter.write(ParquetHiveRecord record)
It writes a record to Parquet.
|
Constructor and Description |
---|
ParquetRecordWriterWrapper(org.apache.hadoop.mapreduce.OutputFormat<Void,ParquetHiveRecord> realOutputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
String name,
org.apache.hadoop.util.Progressable progress,
Properties tableProperties) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.