pyflink.datastream.data_stream.BroadcastConnectedStream.process

BroadcastConnectedStream.process(func: pyflink.datastream.functions.BroadcastProcessFunction, output_type: pyflink.common.typeinfo.TypeInformation = None) → DataStream

BroadcastConnectedStream.process(func: pyflink.datastream.functions.KeyedBroadcastProcessFunction, output_type: pyflink.common.typeinfo.TypeInformation = None) → DataStream

Assumes as inputs a BroadcastStream and a DataStream or KeyedStream and applies the given BroadcastProcessFunction or KeyedBroadcastProcessFunction on them, thereby creating a transformed output stream.

Parameters

• func – The BroadcastProcessFunction that is called for each element in the non-broadcasted DataStream, or the KeyedBroadcastProcessFunction that is called for each element in the non-broadcasted KeyedStream.

• output_type – The type of the output elements, should be common.TypeInformation or list (implicit RowTypeInfo) or None ( implicit Types.PICKLED_BYTE_ARRAY()).

Returns

The transformed DataStream.