org.apache.hadoop.hbase.client.coprocessor.Batch.Callback#org.apache.hadoop.hbase.client.coprocessor.Batch.Call源码实例Demo

@Override
public <T extends Service, R> void coprocessorService(Class<T> service, byte[] startKey,
    byte[] endKey, Call<T, R> callable, Callback<R> callback) throws ServiceException, Throwable {
  coprocssorService(service.getName(), startKey, endKey, callback, channel -> {
    T instance = ProtobufUtil.newServiceStub(service, channel);
    return callable.call(instance);
  });
}
 

@Override
public <T extends Service, R> void coprocessorService(Class<T> service, byte[] startKey,
        byte[] endKey, Call<T, R> callable, Callback<R> callback) throws ServiceException,
        Throwable {
    delegate.coprocessorService(service, startKey, endKey, callable, callback);
    
}
 

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

@Override
public <T extends Service, R> void coprocessorService(Class<T> service, byte[] startKey,
    byte[] endKey, Call<T, R> callable, Callback<R> callback)
throws ServiceException, Throwable {
  throw new UnsupportedOperationException();
}
 

public <T extends Service, R> Map<byte[], R> coprocessorService(
        Class<T> service, byte[] startKey, byte[] endKey, Call<T, R> callable)
        throws ServiceException, Throwable {
  // TODO Auto-generated method stub
  return null;
}
 

public <T extends Service, R> void coprocessorService(Class<T> service,
                                                      byte[] startKey, byte[] endKey,Call<T, R> callable, Callback<R> callback)
        throws ServiceException, Throwable {
  // TODO Auto-generated method stub
}
 

@Override
public <T extends Service, R> Map<byte[], R> coprocessorService(Class<T> service, byte[] startKey, byte[] endKey, Call<T, R> callable)
        throws ServiceException, Throwable {
    return null;
}
 

@Override
public <T extends Service, R> void coprocessorService(Class<T> service, byte[] startKey, byte[] endKey, Call<T, R> callable,
                                                      Callback<R> callback) throws ServiceException, Throwable {

}
 

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

@Override
public <T extends Service, R> void coprocessorService(Class<T> service,
        byte[] startKey, byte[] endKey, Call<T, R> callable,
        Callback<R> callback) throws ServiceException, Throwable {
    throw new UnsupportedOperationException();
}
 

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