org.apache.pinot.tools.data.generator

Class AvroWriter

java.lang.Object

org.apache.pinot.tools.data.generator.AvroWriter

All Implemented Interfaces:

Closeable, AutoCloseable

public class AvroWriter
extends Object
implements Closeable

Constructor Summary

Constructors

Constructor and Description
AvroWriter(File baseDir, int index, Map<String,Generator> generatorMap, org.apache.pinot.spi.data.Schema schema)

Method Summary

Modifier and Type	Method and Description
void	close()
static org.apache.avro.Schema	getAvroSchema(org.apache.pinot.spi.data.Schema schema)
void	writeNext()

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroWriter

public AvroWriter(File baseDir,
                  int index,
                  Map<String,Generator> generatorMap,
                  org.apache.pinot.spi.data.Schema schema)
           throws IOException

Throws:

IOException

Method Detail

getAvroSchema

public static org.apache.avro.Schema getAvroSchema(org.apache.pinot.spi.data.Schema schema)

writeNext

public void writeNext()
               throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException