pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.create_input#
- StreamExecutionEnvironment.create_input(input_format: pyflink.common.io.InputFormat, type_info: Optional[pyflink.common.typeinfo.TypeInformation] = None)[source]#
Create an input data stream with InputFormat.
If the input_format needs a well-defined type information (e.g. Avro’s generic record), you can either explicitly use type_info argument or use InputFormats implementing ResultTypeQueryable.
- Parameters
input_format – The input format to read from.
type_info – Optional type information to explicitly declare output type.
New in version 1.16.0.