Package | Description |
---|---|
parquet.avro |
Provides classes to store Avro data in Parquet files.
|
parquet.example.data | |
parquet.example.data.simple | |
parquet.hadoop.api |
APIs to integrate various type systems with Parquet
|
parquet.hadoop.example | |
parquet.io | |
parquet.schema |
Modifier and Type | Method and Description |
---|---|
void |
AvroWriteSupport.prepareForWrite(RecordConsumer recordConsumer) |
Modifier and Type | Method and Description |
---|---|
abstract void |
Group.writeValue(int field,
int index,
RecordConsumer recordConsumer) |
Constructor and Description |
---|
GroupWriter(RecordConsumer recordConsumer,
GroupType schema) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleGroup.writeValue(int field,
int index,
RecordConsumer recordConsumer) |
void |
NanoTime.writeValue(RecordConsumer recordConsumer) |
void |
FloatValue.writeValue(RecordConsumer recordConsumer) |
void |
BinaryValue.writeValue(RecordConsumer recordConsumer) |
void |
BooleanValue.writeValue(RecordConsumer recordConsumer) |
void |
IntegerValue.writeValue(RecordConsumer recordConsumer) |
void |
LongValue.writeValue(RecordConsumer recordConsumer) |
void |
DoubleValue.writeValue(RecordConsumer recordConsumer) |
abstract void |
Primitive.writeValue(RecordConsumer recordConsumer) |
void |
Int96Value.writeValue(RecordConsumer recordConsumer) |
Modifier and Type | Method and Description |
---|---|
abstract void |
WriteSupport.prepareForWrite(RecordConsumer recordConsumer)
This will be called once per row group
|
Modifier and Type | Method and Description |
---|---|
void |
GroupWriteSupport.prepareForWrite(RecordConsumer recordConsumer) |
Modifier and Type | Class and Description |
---|---|
class |
RecordConsumerLoggingWrapper
This class can be used to wrap an actual RecordConsumer and log all calls
|
class |
ValidatingRecordConsumer
Wraps a record consumer
Validates the record written against the schema and pass down the event to the wrapped consumer
|
Modifier and Type | Field and Description |
---|---|
RecordConsumer |
BaseRecordReader.recordConsumer |
Modifier and Type | Method and Description |
---|---|
RecordConsumer |
MessageColumnIO.getRecordWriter(ColumnWriteStore columns) |
Constructor and Description |
---|
RecordConsumerLoggingWrapper(RecordConsumer delegate)
all calls a delegate to the wrapped delegate
|
ValidatingRecordConsumer(RecordConsumer delegate,
MessageType schema) |
Modifier and Type | Method and Description |
---|---|
abstract void |
PrimitiveType.PrimitiveTypeName.addValueToRecordConsumer(RecordConsumer recordConsumer,
ColumnReader columnReader)
reads the value from the columnReader with the appropriate accessor and writes it to the recordConsumer
|
Copyright © 2015. All rights reserved.