org.apache.hadoop.hive.ql.io.parquet.write

Class DataWritableWriteSupport

java.lang.Object

org.apache.parquet.hadoop.api.WriteSupport<ParquetHiveRecord>

org.apache.hadoop.hive.ql.io.parquet.write.DataWritableWriteSupport

public class DataWritableWriteSupport
extends org.apache.parquet.hadoop.api.WriteSupport<ParquetHiveRecord>

DataWritableWriteSupport is a WriteSupport for the DataWritableWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.parquet.hadoop.api.WriteSupport

org.apache.parquet.hadoop.api.WriteSupport.FinalizedWriteContext, org.apache.parquet.hadoop.api.WriteSupport.WriteContext

Field Summary

Fields

Modifier and Type	Field and Description
static String	PARQUET_HIVE_SCHEMA

Constructor Summary

Constructors

Constructor and Description
DataWritableWriteSupport()

Method Summary

Modifier and Type	Method and Description
static org.apache.parquet.schema.MessageType	getSchema(org.apache.hadoop.conf.Configuration configuration)
org.apache.parquet.hadoop.api.WriteSupport.WriteContext	init(org.apache.hadoop.conf.Configuration configuration)
void	prepareForWrite(org.apache.parquet.io.api.RecordConsumer recordConsumer)
static void	setSchema(org.apache.parquet.schema.MessageType schema, org.apache.hadoop.conf.Configuration configuration)
void	write(ParquetHiveRecord record)

Methods inherited from class org.apache.parquet.hadoop.api.WriteSupport

finalizeWrite, getName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PARQUET_HIVE_SCHEMA

public static final String PARQUET_HIVE_SCHEMA

See Also:

Constant Field Values

Constructor Detail

DataWritableWriteSupport

public DataWritableWriteSupport()

Method Detail

setSchema

public static void setSchema(org.apache.parquet.schema.MessageType schema,
                             org.apache.hadoop.conf.Configuration configuration)

getSchema

public static org.apache.parquet.schema.MessageType getSchema(org.apache.hadoop.conf.Configuration configuration)

init

public org.apache.parquet.hadoop.api.WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)

Specified by:

init in class org.apache.parquet.hadoop.api.WriteSupport<ParquetHiveRecord>

prepareForWrite

public void prepareForWrite(org.apache.parquet.io.api.RecordConsumer recordConsumer)

Specified by:

prepareForWrite in class org.apache.parquet.hadoop.api.WriteSupport<ParquetHiveRecord>

write

public void write(ParquetHiveRecord record)

Specified by:

write in class org.apache.parquet.hadoop.api.WriteSupport<ParquetHiveRecord>