code: @Override
  	public void open(Configuration config) throws IOException {
  		streamer.open();
  		streamer.sendBroadCastVariables(config);
  	}
docs: Opens this function.
  
  @param config configuration
  @throws IOException