org.apache.flink.api.java.typeutils

Interface InputTypeConfigurable

All Known Implementing Classes:

AvroKeyValueSinkWriter, BucketingSink, CsvOutputFormat, LocalCollectionOutputFormat, OutputFormatSinkFunction, RollingSink, ScalaCsvOutputFormat, SequenceFileWriter, TypeSerializerOutputFormat

@Public
public interface InputTypeConfigurable

OutputFormats can implement this interface to be configured with the data type they will operate on. The method setInputType(TypeInformation, ExecutionConfig) will be called when the output format is used with an output API method.

Method Summary

Modifier and Type	Method and Description
void	setInputType(TypeInformation<?> type, ExecutionConfig executionConfig) Method that is called on an OutputFormat when it is passed to the DataSet's output method.

Method Detail

setInputType

void setInputType(TypeInformation<?> type,
                  ExecutionConfig executionConfig)

Method that is called on an OutputFormat when it is passed to the DataSet's output method. May be used to configures the output format based on the data type.

Parameters:

type - The data type of the input.

executionConfig - The execution config for this parallel execution.