public void setLocation()

in src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java [182:197]

• 14 lines of code
• 3 McCabe index (conditional complexity)

  public void setLocation(String location, Job job) throws IOException {
    conf = job.getConfiguration();
    setLocationFromUri(location);
    
    if (!conf.getBoolean(AccumuloInputFormat.class.getSimpleName() + ".configured", false)) {
      AccumuloInputFormat.setInputInfo(conf, user, password.getBytes(), table, authorizations);
      AccumuloInputFormat.setZooKeeperInstance(conf, inst, zookeepers);
      if (columnFamilyColumnQualifierPairs.size() > 0) {
        LOG.info("columns: " + columnFamilyColumnQualifierPairs);
        AccumuloInputFormat.fetchColumns(conf, columnFamilyColumnQualifierPairs);
      }
      
      AccumuloInputFormat.setRanges(conf, Collections.singleton(new Range(start, end)));
      configureInputFormat(conf);
    }
  }