org.apache.flink.runtime.jobgraph

Class InputOutputFormatContainer

java.lang.Object

org.apache.flink.runtime.jobgraph.InputOutputFormatContainer

public class InputOutputFormatContainer
extends Object

A container for InputFormats and OutputFormats, along with their Configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InputOutputFormatContainer.FormatUserCodeTable Container for multiple wrappers containing InputFormat and OutputFormat code.

Constructor Summary

Constructors

Constructor and Description
InputOutputFormatContainer(ClassLoader classLoader)
InputOutputFormatContainer(TaskConfig config, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
InputOutputFormatContainer	addInputFormat(OperatorID operatorId, InputFormat<?,?> inputFormat)
InputOutputFormatContainer	addInputFormat(OperatorID operatorId, UserCodeWrapper<? extends InputFormat<?,?>> wrapper)
InputOutputFormatContainer	addOutputFormat(OperatorID operatorId, OutputFormat<?> outputFormat)
InputOutputFormatContainer	addOutputFormat(OperatorID operatorId, UserCodeWrapper<? extends OutputFormat<?>> wrapper)
InputOutputFormatContainer	addParameters(OperatorID operatorId, Configuration parameters)
InputOutputFormatContainer	addParameters(OperatorID operatorId, String key, String value)
Map<OperatorID,UserCodeWrapper<? extends InputFormat<?,?>>>	getInputFormats()
Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>>	getOutputFormats()
Configuration	getParameters(OperatorID operatorId)
<OT,T extends InputSplit> org.apache.commons.lang3.tuple.Pair<OperatorID,InputFormat<OT,T>>	getUniqueInputFormat()
<IT> org.apache.commons.lang3.tuple.Pair<OperatorID,OutputFormat<IT>>	getUniqueOutputFormat()
void	write(TaskConfig config)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputOutputFormatContainer

public InputOutputFormatContainer(ClassLoader classLoader)

InputOutputFormatContainer

public InputOutputFormatContainer(TaskConfig config,
                                  ClassLoader classLoader)

Method Detail

getInputFormats

public Map<OperatorID,UserCodeWrapper<? extends InputFormat<?,?>>> getInputFormats()

getOutputFormats

public Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>> getOutputFormats()

getUniqueInputFormat

public <OT,T extends InputSplit> org.apache.commons.lang3.tuple.Pair<OperatorID,InputFormat<OT,T>> getUniqueInputFormat()

getUniqueOutputFormat

public <IT> org.apache.commons.lang3.tuple.Pair<OperatorID,OutputFormat<IT>> getUniqueOutputFormat()

addInputFormat

public InputOutputFormatContainer addInputFormat(OperatorID operatorId,
                                                 InputFormat<?,?> inputFormat)

addInputFormat

public InputOutputFormatContainer addInputFormat(OperatorID operatorId,
                                                 UserCodeWrapper<? extends InputFormat<?,?>> wrapper)

addOutputFormat

public InputOutputFormatContainer addOutputFormat(OperatorID operatorId,
                                                  OutputFormat<?> outputFormat)

addOutputFormat

public InputOutputFormatContainer addOutputFormat(OperatorID operatorId,
                                                  UserCodeWrapper<? extends OutputFormat<?>> wrapper)

getParameters

public Configuration getParameters(OperatorID operatorId)

addParameters

public InputOutputFormatContainer addParameters(OperatorID operatorId,
                                                Configuration parameters)

addParameters

public InputOutputFormatContainer addParameters(OperatorID operatorId,
                                                String key,
                                                String value)

write

public void write(TaskConfig config)