com.ailbb.act.file.parquet

Class $ParquetSchemaWriter

java.lang.Object

com.ailbb.act.file.parquet.$ParquetSchemaWriter

public class $ParquetSchemaWriter
extends Object

Constructor Summary

Constructors

Constructor and Description
$ParquetSchemaWriter(org.apache.parquet.hadoop.ParquetWriter<org.apache.avro.generic.GenericRecord> writer, org.apache.avro.Schema schema)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.avro.Schema	getSchema()
org.apache.parquet.hadoop.ParquetWriter<org.apache.avro.generic.GenericRecord>	getWriter()
$ParquetSchemaWriter	setSchema(org.apache.avro.Schema schema)
$ParquetSchemaWriter	setWriter(org.apache.parquet.hadoop.ParquetWriter<org.apache.avro.generic.GenericRecord> writer)
$ParquetSchemaWriter	write(org.apache.avro.generic.GenericRecord record)
$ParquetSchemaWriter	write(List<Object> ol)
$ParquetSchemaWriter	write(Object o)

Methods inherited from class java.lang.Object

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

Constructor Detail

$ParquetSchemaWriter

public $ParquetSchemaWriter(org.apache.parquet.hadoop.ParquetWriter<org.apache.avro.generic.GenericRecord> writer,
                            org.apache.avro.Schema schema)

Method Detail

write

public $ParquetSchemaWriter write(org.apache.avro.generic.GenericRecord record)
                           throws IOException

Throws:

IOException

write

public $ParquetSchemaWriter write(Object o)
                           throws IOException,
                                  InvocationTargetException,
                                  IllegalAccessException

Throws:

IOException

InvocationTargetException

IllegalAccessException

write

public $ParquetSchemaWriter write(List<Object> ol)
                           throws IOException,
                                  InvocationTargetException,
                                  IllegalAccessException

Throws:

IOException

InvocationTargetException

IllegalAccessException

close

public void close()
           throws IOException

Throws:

IOException

getWriter

public org.apache.parquet.hadoop.ParquetWriter<org.apache.avro.generic.GenericRecord> getWriter()

setWriter

public $ParquetSchemaWriter setWriter(org.apache.parquet.hadoop.ParquetWriter<org.apache.avro.generic.GenericRecord> writer)

getSchema

public org.apache.avro.Schema getSchema()

setSchema

public $ParquetSchemaWriter setSchema(org.apache.avro.Schema schema)