code: @Override
  	public void open(InputSplit ignored) throws IOException {
  		this.session = cluster.connect();
  		this.resultSet = session.execute(query);
  	}
docs: Opens a Session and executes the query.
  
  @param ignored because parameter is not parallelizable.
  @throws IOException