public class GroupWriteSupport extends WriteSupport<Group>
WriteSupport.WriteContext
Modifier and Type | Field and Description |
---|---|
static String |
PARQUET_EXAMPLE_SCHEMA |
Constructor and Description |
---|
GroupWriteSupport() |
Modifier and Type | Method and Description |
---|---|
static MessageType |
getSchema(org.apache.hadoop.conf.Configuration configuration) |
WriteSupport.WriteContext |
init(org.apache.hadoop.conf.Configuration configuration)
called first in the task
|
void |
prepareForWrite(RecordConsumer recordConsumer)
This will be called once per row group
|
static void |
setSchema(MessageType schema,
org.apache.hadoop.conf.Configuration configuration) |
void |
write(Group record)
called once per record
|
public static final String PARQUET_EXAMPLE_SCHEMA
public static void setSchema(MessageType schema, org.apache.hadoop.conf.Configuration configuration)
public static MessageType getSchema(org.apache.hadoop.conf.Configuration configuration)
public WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)
WriteSupport
init
in class WriteSupport<Group>
configuration
- the job's configurationpublic void prepareForWrite(RecordConsumer recordConsumer)
WriteSupport
prepareForWrite
in class WriteSupport<Group>
recordConsumer
- the recordConsumer to write topublic void write(Group record)
WriteSupport
write
in class WriteSupport<Group>
record
- one record to write to the previously provided record consumerCopyright © 2015. All rights reserved.