docs: @Override
  	public void open(int taskNumber, int numTasks) {
  		this.session = cluster.connect();
  		MappingManager mappingManager = new MappingManager(session);
  		this.mapper = mappingManager.mapper(outputClass);
  		if (mapperOptions != null) {
  			Mapper.Option[] optionsArray = mapperOptions.getMapperOptions();
  			if (optionsArray != null) {
  				mapper.setDefaultSaveOptions(optionsArray);
  			}
  		}
  		this.callback = new FutureCallback<Void>() {
  			@Override
  			public void onSuccess(Void ignored) {
  				onWriteSuccess();
  			}
  
  			@Override
  			public void onFailure(Throwable t) {
  				onWriteFailure(t);
  			}
  		};
  	}