T
- the type of the incoming recordspublic abstract class WriteSupport<T> extends Object
ParquetOutputFormat
to convert incoming recordsModifier and Type | Class and Description |
---|---|
static class |
WriteSupport.WriteContext
information to be persisted in the file
|
Constructor and Description |
---|
WriteSupport() |
Modifier and Type | Method and Description |
---|---|
abstract WriteSupport.WriteContext |
init(org.apache.hadoop.conf.Configuration configuration)
called first in the task
|
abstract void |
prepareForWrite(RecordConsumer recordConsumer)
This will be called once per row group
|
abstract void |
write(T record)
called once per record
|
public abstract WriteSupport.WriteContext init(org.apache.hadoop.conf.Configuration configuration)
configuration
- the job's configurationpublic abstract void prepareForWrite(RecordConsumer recordConsumer)
recordConsumer
- the recordConsumer to write topublic abstract void write(T record)
record
- one record to write to the previously provided record consumerCopyright © 2015. All rights reserved.