pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.create_input

StreamExecutionEnvironment.create_input(input_format: InputFormat, type_info: TypeInformation | None = None)

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.

Added in version 1.16.0.