docs: @PublicEvolving
  	public BroadcastStream<T> broadcast(final MapStateDescriptor<?, ?>... broadcastStateDescriptors) {
  		Preconditions.checkNotNull(broadcastStateDescriptors);
  		final DataStream<T> broadcastStream = setConnectionType(new BroadcastPartitioner<>());
  		return new BroadcastStream<>(environment, broadcastStream, broadcastStateDescriptors);
  	}