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