org.apache.flink.api.java.typeutils

Interface ResultTypeQueryable<T>

All Known Subinterfaces:

BulkFormat<T,SplitT>, DataStreamPythonFunctionOperator<OUT>, DataStreamSinkExternalContext<T>, DataStreamSinkV1ExternalContext<T>, DataStreamSinkV2ExternalContext<T>, DataStreamSourceExternalContext<T>, DeserializationSchema<T>, DeserializationSchema<T>, FileRecordFormat<T>, KafkaDeserializationSchema<T>, KafkaRecordDeserializationSchema<T>, KeyedDeserializationSchema<T>, RowDataKeySelector, StreamFormat<T>

All Known Implementing Classes:

AbstractAvroBulkFormat, AbstractDeserializationSchema, AbstractDeserializationSchema, AbstractEmbeddedDataStreamPythonFunctionOperator, AbstractExternalDataStreamPythonFunctionOperator, AbstractExternalOneInputPythonFunctionOperator, AbstractExternalTwoInputPythonFunctionOperator, AbstractFileSource, AbstractOneInputEmbeddedPythonFunctionOperator, AbstractOrcFileInputFormat, AbstractTwoInputEmbeddedPythonFunctionOperator, ArrowSourceFunction, AvroDeserializationSchema, AvroInputFormat, AvroRowDataDeserializationSchema, AvroRowDeserializationSchema, BinaryRowDataKeySelector, CanalJsonDeserializationSchema, ChangelogCsvDeserializer, ConfluentRegistryAvroDeserializationSchema, CsvReaderFormat, CsvRowDataDeserializationSchema, CsvRowDeserializationSchema, DataGeneratorSource, DebeziumAvroDeserializationSchema, DebeziumJsonDeserializationSchema, DelegateOperatorTransformation.DelegateOperator, DeserializationSchemaAdapter, EmbeddedPythonBatchCoBroadcastProcessOperator, EmbeddedPythonBatchKeyedCoBroadcastProcessOperator, EmbeddedPythonCoProcessOperator, EmbeddedPythonKeyedCoProcessOperator, EmbeddedPythonKeyedProcessOperator, EmbeddedPythonProcessOperator, EmbeddedPythonWindowOperator, EmptyRowDataKeySelector, EventDeSerializationSchema, ExternalPythonBatchCoBroadcastProcessOperator, ExternalPythonBatchKeyedCoBroadcastProcessOperator, ExternalPythonCoProcessOperator, ExternalPythonKeyedCoProcessOperator, ExternalPythonKeyedProcessOperator, ExternalPythonProcessOperator, FileRecordFormatAdapter, FileSource, FilterAllFlatMapFunction, FlinkKafkaConsumer, FlinkKafkaConsumerBase, FlinkKafkaShuffleConsumer, GenericRowDataKeySelector, HadoopInputFormat, HadoopInputFormat, HadoopMapFunction, HadoopReduceCombineFunction, HadoopReduceFunction, HiveBulkFormatAdapter, HiveInputFormat, HiveSource, IntervalJoinFunction, JsonDeserializationSchema, JSONKeyValueDeserializationSchema, JsonNodeDeserializationSchema, JsonRowDataDeserializationSchema, JsonRowDeserializationSchema, KafkaDeserializationSchemaWrapper, KafkaEventSchema, KafkaSource, KeySelectorUtil.ArrayKeySelector, KeySelectorUtil.ComparableKeySelector, LimitableBulkFormat, MaxwellJsonDeserializationSchema, NumberSequenceSource, OggJsonDeserializationSchema, OrcColumnarRowFileInputFormat, OrcColumnarRowInputFormat, PaddingLeftMapFunction, PaddingRightMapFunction, ParquetColumnarRowInputFormat, ParquetVectorizedInputFormat, PbRowDataDeserializationSchema, PeriodicStreamingJob.PeriodicSourceGenerator, RawFormatDeserializationSchema, RegistryAvroDeserializationSchema, RowCsvInputFormat, SimpleStreamFormat, SimpleStringSchema, SimpleStringSchema, SocketSourceFunction, StreamFormatAdapter, StreamSQLTestProgram.Generator, StreamSQLTestProgram.KillMapper, TextLineFormat, TextLineInputFormat, TypeInformationKeyValueSerializationSchema, TypeInformationSerializationSchema, TypeInformationSerializationSchema, TypeSerializerInputFormat, ValuesInputFormat

@Public
public interface ResultTypeQueryable<T>

This interface can be implemented by functions and input formats to tell the framework about their produced data type. This method acts as an alternative to the reflection analysis that is otherwise performed and is useful in situations where the produced data type may vary depending on parametrization.

Method Summary

Modifier and Type	Method and Description
TypeInformation<T>	getProducedType() Gets the data type (as a TypeInformation) produced by this function or input format.

Method Detail

getProducedType

TypeInformation<T> getProducedType()

Gets the data type (as a TypeInformation) produced by this function or input format.

Returns:

The data type produced by this function or input format.