/**
 * Parse the resolver configuration
 * @param resolverConfig
 * @return
 */
public List<Resolver> createResolvers(String resolverConfig)
{
  String[] specs = resolverConfig.split(",");
  List<Resolver> resolvers = new ArrayList<>(specs.length);
  for (String s : specs) {
    s = s.trim();
    String[] comps = s.split(":");
    if (comps.length == 0) {
      throw new IllegalArgumentException(String.format("Invalid resolver spec %s in %s", s, resolverConfig));
    }
    if (SCHEME_MANIFEST.equals(comps[0])) {
      if (comps.length < 2) {
        throw new IllegalArgumentException(String.format("Missing repository path in manifest resolver spec %s in %s", s, resolverConfig));
      }
      File baseDir = new File(comps[1]);
      resolvers.add(new ManifestResolver(baseDir));
    } else if (SCHEME_MVN.equals(comps[0])) {
      MavenResolver mvnr = new MavenResolver();
      if (comps.length > 1) {
        mvnr.userHome = comps[1];
      }
      resolvers.add(mvnr);
    } else {
      throw new NotImplementedException("Unknown resolver scheme " + comps[0]);
    }
  }
  return resolvers;
}
 

@Override
public <R extends Message> void batchCoprocessorService(Descriptors.MethodDescriptor methodDescriptor,
        Message request, byte[] startKey, byte[] endKey, R responsePrototype, Batch.Callback<R> callback)
        throws ServiceException, Throwable {
    throw new NotImplementedException();

}
 

public float getProgress() {
    throw new NotImplementedException();
}
 

@Override
public void copyFrom( FileObject arg0, FileSelector arg1 ) throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public void dump(GTIDSet gtidSet, SinkFunction func) throws IOException {
    throw new NotImplementedException();
}
 

@Override
public int getNumReduceTasks() {
    throw new NotImplementedException();
}
 

@Override
public void setStatus(String msg) {
    throw new NotImplementedException();
}
 

@Override
public void findFiles( FileSelector arg0, boolean arg1, @SuppressWarnings( "rawtypes" ) List arg2 ) throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public FileObject getChild( String arg0 ) throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public FileObject[] getChildren() throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public Object getCurrentValue() throws IOException, InterruptedException {
    throw new NotImplementedException();
}
 

@Override
public FileOperations getFileOperations() throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public FileSystem getFileSystem() {
  throw new NotImplementedException();
}
 

@Override
public String getUser() {
    throw new NotImplementedException();
}
 

@Override
public FileObject getParent() throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override public String getPublicURIString() {
  throw new NotImplementedException();
}
 

@Override
public RawComparator<?> getSortComparator() {
    throw new NotImplementedException();
}
 

@Override public boolean isExecutable() throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public boolean getJobSetupCleanupNeeded() {
    throw new NotImplementedException();
}
 

@Override
public RawComparator<?> getGroupingComparator() {
    throw new NotImplementedException();
}
 

@Override
public void moveTo( FileObject arg0 ) throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public FileObject resolveFile( String arg0 ) throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public FileObject resolveFile( String arg0, NameScope arg1 ) throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override
public void dump(GTIDSet gtidSet, MultiStageCoprocessor coprocessor) throws IOException {
    throw new NotImplementedException();
}
 

@Override
public Class<? extends OutputFormat<?, ?>> getOutputFormatClass() throws ClassNotFoundException {
    throw new NotImplementedException();
}
 

@Override public boolean setWritable( boolean b, boolean b1 ) throws FileSystemException {
  throw new NotImplementedException();
}
 

@Override public int compareTo( FileObject o ) {
  throw new NotImplementedException();
}
 

@Override public Iterator<FileObject> iterator() {
  throw new NotImplementedException();
}
 

@Override
public <T extends Service, R> Map<byte[], R> coprocessorService(Class<T> service, byte[] startKey, byte[] endKey,
        Batch.Call<T, R> callable) throws ServiceException, Throwable {
    throw new NotImplementedException();

}
 

@Override
public Class<? extends Mapper<?, ?, ?, ?>> getMapperClass() throws ClassNotFoundException {
    throw new NotImplementedException();
}