org.apache.flink.api.common.io

Class RichOutputFormat<IT>

java.lang.Object

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

All Implemented Interfaces:

Serializable, OutputFormat<IT>

Direct Known Subclasses:

FileOutputFormat, HadoopOutputFormatCommonBase, LocalCollectionOutputFormat, OutputFormatBase, PrintingOutputFormat, SavepointOutputFormat, Utils.ChecksumHashCodeHelper, Utils.CollectHelper, Utils.CountHelper

@Public
public abstract class RichOutputFormat<IT>
extends Object
implements OutputFormat<IT>

An abstract stub implementation for Rich output formats. Rich formats have access to their runtime execution context via getRuntimeContext().

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.common.io.OutputFormat

OutputFormat.InitializationContext

Constructor Summary

Constructors

Constructor and Description
RichOutputFormat()

Method Summary

Modifier and Type	Method and Description
RuntimeContext	getRuntimeContext()
void	setRuntimeContext(RuntimeContext t)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.io.OutputFormat

close, configure, open, open, writeRecord

Constructor Detail

RichOutputFormat

public RichOutputFormat()

Method Detail

setRuntimeContext

public void setRuntimeContext(RuntimeContext t)

getRuntimeContext

public RuntimeContext getRuntimeContext()