org.apache.flink.api.java.io

Class AvroOutputFormat<E>

java.lang.Object

org.apache.flink.api.common.io.RichOutputFormat<IT>

org.apache.flink.api.common.io.FileOutputFormat<E>

org.apache.flink.api.java.io.AvroOutputFormat<E>

All Implemented Interfaces:

Serializable, CleanupWhenUnsuccessful, InitializeOnMaster, OutputFormat<E>

public class AvroOutputFormat<E>
extends FileOutputFormat<E>
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AvroOutputFormat.Codec Wrapper which encapsulates the supported codec and a related serialization byte.

Nested classes/interfaces inherited from class org.apache.flink.api.common.io.FileOutputFormat

FileOutputFormat.OutputDirectoryMode

Field Summary

Fields inherited from class org.apache.flink.api.common.io.FileOutputFormat

FILE_PARAMETER_KEY, outputFilePath, stream

Constructor Summary

Constructors

Constructor and Description
AvroOutputFormat(Class<E> type)
AvroOutputFormat(Path filePath, Class<E> type)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected String	getDirectoryFileName(int taskNumber)
void	open(int taskNumber, int numTasks)
void	setCodec(AvroOutputFormat.Codec codec) Set avro codec for compression.
void	setSchema(org.apache.avro.Schema schema)
void	writeRecord(E record)

Methods inherited from class org.apache.flink.api.common.io.FileOutputFormat

configure, getOutputDirectoryMode, getOutputFilePath, getWriteMode, initializeGlobal, setOutputDirectoryMode, setOutputFilePath, setWriteMode, tryCleanupOnError

Methods inherited from class org.apache.flink.api.common.io.RichOutputFormat

getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroOutputFormat

public AvroOutputFormat(Path filePath,
                Class<E> type)

AvroOutputFormat

public AvroOutputFormat(Class<E> type)

Method Detail

getDirectoryFileName

protected String getDirectoryFileName(int taskNumber)

Overrides:

getDirectoryFileName in class FileOutputFormat<E>

setSchema

public void setSchema(org.apache.avro.Schema schema)

setCodec

public void setCodec(AvroOutputFormat.Codec codec)

Set avro codec for compression.

Parameters:

codec - avro codec.

writeRecord

public void writeRecord(E record)
                 throws IOException

Specified by:

writeRecord in interface OutputFormat<E>

Throws:

IOException

open

public void open(int taskNumber,
        int numTasks)
          throws IOException

Specified by:

open in interface OutputFormat<E>

Overrides:

open in class FileOutputFormat<E>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface OutputFormat<E>

Overrides:

close in class FileOutputFormat<E>

Throws:

IOException