pyflink.datastream.data_stream.AllWindowedStream.get_input_type# AllWindowedStream.get_input_type()[source]#