public void setStoreLocation()

in src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java [226:238]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  public void setStoreLocation(String location, Job job) throws IOException {
    conf = job.getConfiguration();
    setLocationFromUri(location);
    
    if (!conf.getBoolean(AccumuloOutputFormat.class.getSimpleName() + ".configured", false)) {
      AccumuloOutputFormat.setOutputInfo(conf, user, password.getBytes(), true, table);
      AccumuloOutputFormat.setZooKeeperInstance(conf, inst, zookeepers);
      AccumuloOutputFormat.setMaxLatency(conf, maxLatency);
      AccumuloOutputFormat.setMaxMutationBufferSize(conf, maxMutationBufferSize);
      AccumuloOutputFormat.setMaxWriteThreads(conf, maxWriteThreads);
      configureOutputFormat(conf);
    }
  }