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, org.apache.flink.api.common.io.CleanupWhenUnsuccessful, org.apache.flink.api.common.io.InitializeOnMaster, org.apache.flink.api.common.io.OutputFormat<E>

public class AvroOutputFormat<E>
extends org.apache.flink.api.common.io.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

org.apache.flink.api.common.io.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(org.apache.flink.core.fs.Path filePath, Class<E> type)

Method Summary

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(org.apache.flink.core.fs.Path filePath,
                        Class<E> type)

AvroOutputFormat

public AvroOutputFormat(Class<E> type)

Method Detail

getDirectoryFileName

protected String getDirectoryFileName(int taskNumber)

Overrides:

getDirectoryFileName in class org.apache.flink.api.common.io.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 org.apache.flink.api.common.io.OutputFormat<E>

Throws:

IOException

open

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

Specified by:

open in interface org.apache.flink.api.common.io.OutputFormat<E>

Overrides:

open in class org.apache.flink.api.common.io.FileOutputFormat<E>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.flink.api.common.io.OutputFormat<E>

Overrides:

close in class org.apache.flink.api.common.io.FileOutputFormat<E>

Throws:

IOException