code: public void configure(JobConf job) {
  
      dbConf = new DBConfiguration(job);
  
      try {
        this.connection = dbConf.getConnection();
        this.connection.setAutoCommit(false);
        connection.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);
      }
      catch (Exception ex) {
        throw new RuntimeException(ex);
      }
  
      tableName = dbConf.getInputTableName();
      fieldNames = dbConf.getInputFieldNames();
      conditions = dbConf.getInputConditions();
    }
docs: {@inheritDoc}