org.apache.flink.api.java.hadoop.common

Class HadoopOutputFormatCommonBase<T>

java.lang.Object

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

org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase<T>

All Implemented Interfaces:

Serializable, OutputFormat<T>

Direct Known Subclasses:

HadoopOutputFormatBase, HadoopOutputFormatBase

@Internal
public abstract class HadoopOutputFormatCommonBase<T>
extends RichOutputFormat<T>

A common base for both "mapred" and "mapreduce" Hadoop output formats.

The base is taking care of handling (serializing) security credentials.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.security.Credentials	credentials

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HadoopOutputFormatCommonBase(org.apache.hadoop.security.Credentials creds)

Method Summary

Modifier and Type	Method and Description
void	read(ObjectInputStream in)
protected void	write(ObjectOutputStream out)

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

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

close, configure, open, writeRecord

Field Detail

credentials

protected transient org.apache.hadoop.security.Credentials credentials

Constructor Detail

HadoopOutputFormatCommonBase

protected HadoopOutputFormatCommonBase(org.apache.hadoop.security.Credentials creds)

Method Detail

write

protected void write(ObjectOutputStream out)
              throws IOException

Throws:

IOException

read

public void read(ObjectInputStream in)
          throws IOException

Throws:

IOException