pyflink.datastream.data_stream.BroadcastConnectedStream.process

BroadcastConnectedStream.process(func: BroadcastProcessFunction, output_type: TypeInformation = None) → DataStream

BroadcastConnectedStream.process(func: KeyedBroadcastProcessFunction, output_type: 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.