class CoBroadcastWithNonKeyedOperator extends AbstractUdfStreamOperator<OUT, BroadcastProcessFunction<IN1, IN2, OUT>> implements TwoInputStreamOperator<IN1, IN2, OUT> {

	@Override
	public void processElement1(StreamRecord<IN1> element) throws Exception {
		collector.setTimestamp(element);
		rContext.setElement(element);
		userFunction.processElement(element.getValue(), rContext, collector);
		rContext.setElement(null);
	}

	public  CoBroadcastWithNonKeyedOperator(
			final BroadcastProcessFunction<IN1, IN2, OUT> function,
			final List<MapStateDescriptor<?, ?>> broadcastStateDescriptors);

}