public class DataWritableWriteSupport extends parquet.hadoop.api.WriteSupport<ParquetHiveRecord>
Modifier and Type | Field and Description |
---|---|
static String |
PARQUET_HIVE_SCHEMA |
Constructor and Description |
---|
DataWritableWriteSupport() |
Modifier and Type | Method and Description |
---|---|
static parquet.schema.MessageType |
getSchema(org.apache.hadoop.conf.Configuration configuration) |
parquet.hadoop.api.WriteSupport.WriteContext |
init(org.apache.hadoop.conf.Configuration configuration) |
void |
prepareForWrite(parquet.io.api.RecordConsumer recordConsumer) |
static void |
setSchema(parquet.schema.MessageType schema,
org.apache.hadoop.conf.Configuration configuration) |
void |
write(ParquetHiveRecord record) |
public static final String PARQUET_HIVE_SCHEMA
public static void setSchema(parquet.schema.MessageType schema, org.apache.hadoop.conf.Configuration configuration)
public static parquet.schema.MessageType getSchema(org.apache.hadoop.conf.Configuration configuration)
public parquet.hadoop.api.WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)
init
in class parquet.hadoop.api.WriteSupport<ParquetHiveRecord>
public void prepareForWrite(parquet.io.api.RecordConsumer recordConsumer)
prepareForWrite
in class parquet.hadoop.api.WriteSupport<ParquetHiveRecord>
public void write(ParquetHiveRecord record)
write
in class parquet.hadoop.api.WriteSupport<ParquetHiveRecord>
Copyright © 2017 The Apache Software Foundation. All rights reserved.