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

java.lang.Object
  parquet.hadoop.api.WriteSupport<org.apache.hadoop.io.ArrayWritable>
      org.apache.hadoop.hive.ql.io.parquet.write.DataWritableWriteSupport

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

DataWritableWriteSupport is a WriteSupport for the DataWritableWriter

Nested Class Summary

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

parquet.hadoop.api.WriteSupport.WriteContext

Field Summary

static String

PARQUET_HIVE_SCHEMA

Constructor Summary

DataWritableWriteSupport()

Method Summary

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(org.apache.hadoop.io.ArrayWritable record)

Methods inherited from class java.lang.Object

equals, 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(parquet.schema.MessageType schema,
                             org.apache.hadoop.conf.Configuration configuration)

getSchema

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

init

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

Specified by:

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

prepareForWrite

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

Specified by:

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

write

public void write(org.apache.hadoop.io.ArrayWritable record)

Specified by:

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