docs: @Override
  	public void open(int taskNumber, int numTasks) throws IOException {
  		this.session = cluster.connect();
  		this.prepared = session.prepare(insertQuery);
  		this.callback = new FutureCallback<ResultSet>() {
  			@Override
  			public void onSuccess(ResultSet ignored) {
  				onWriteSuccess(ignored);
  			}
  
  			@Override
  			public void onFailure(Throwable t) {
  				onWriteFailure(t);
  			}
  		};
  	}