Java 类org.apache.hadoop.hbase.client.coprocessor.Batch.Call 实例源码

@Override
public <T extends CoprocessorProtocol, R> Map<byte[], R> coprocessorExec(
  Class<T> protocol, byte[] startKey, byte[] endKey, Call<T, R> callable) throws IOException,
  Throwable {
  // TODO Auto-generated method stub
  return null;
}

@Override
public <T extends CoprocessorProtocol, R> void coprocessorExec(
  Class<T> protocol, byte[] startKey, byte[] endKey, Call<T, R> callable, Callback<R> callback)
  throws IOException, Throwable {
  // TODO Auto-generated method stub

}

public <T extends CoprocessorProtocol, R> Map<byte[], R> coprocessorExec(
        String tableName, Class<T> paramClass, byte[] paramArrayOfByte1,
        byte[] paramArrayOfByte2, Call<T, R> paramCall) throws IOException,
        Throwable {
    return poolableHConnection.coprocessorExec(tableName, paramClass,
            paramArrayOfByte1, paramArrayOfByte2, paramCall);
}

public <T extends CoprocessorProtocol, R> void coprocessorExec(
        String tableName, Class<T> paramClass, byte[] paramArrayOfByte1,
        byte[] paramArrayOfByte2, Call<T, R> paramCall,
        Callback<R> paramCallback) throws IOException, Throwable {
    poolableHConnection.coprocessorExec(tableName, paramClass,
            paramArrayOfByte1, paramArrayOfByte2, paramCall, paramCallback);
}

public <T extends CoprocessorProtocol, R> Map<byte[], R> coprocessorExec(String tableName, Class<T> paramClass,
        byte[] paramArrayOfByte1, byte[] paramArrayOfByte2, Call<T, R> paramCall) {
    try {
        return hzTemplate.coprocessorExec(tableName, paramClass, paramArrayOfByte1, paramArrayOfByte2, paramCall);
    } catch (Throwable ex) {
        throw new HzBaoException(ex);
    }
}

public <T extends CoprocessorProtocol, R> void coprocessorExec(String tableName, Class<T> paramClass,
        byte[] paramArrayOfByte1, byte[] paramArrayOfByte2, Call<T, R> paramCall, Callback<R> paramCallback) {
    try {
        hzTemplate.coprocessorExec(tableName, paramClass, paramArrayOfByte1, paramArrayOfByte2, paramCall,
                paramCallback);
    } catch (Throwable ex) {
        throw new HzBaoException(ex);
    }
}

@Override
public <T extends CoprocessorProtocol, R> Map<byte[], R> coprocessorExec(String tableName,
        final Class<T> paramClass, final byte[] paramArrayOfByte1, final byte[] paramArrayOfByte2,
        final Call<T, R> paramCall) throws IOException, Throwable {
    return execute(tableName, new HzTableCallback<Map<byte[], R>>() {
        public Map<byte[], R> doInAction(HTableInterface table) throws HzTemplateException {
            try {
                return table.coprocessorExec(paramClass, paramArrayOfByte1, paramArrayOfByte2, paramCall);
            } catch (Throwable ex) {
                throw new HzTemplateException(ex);
            }
        }
    });
}

public <T extends CoprocessorProtocol, R> void coprocessorExec(String tableName, final Class<T> paramClass,
        final byte[] paramArrayOfByte1, final byte[] paramArrayOfByte2, final Call<T, R> paramCall,
        final Callback<R> paramCallback) throws IOException, Throwable {
    execute(tableName, new HzTableCallback<Object>() {
        public Object doInAction(HTableInterface table) throws HzTemplateException {
            try {
                table.coprocessorExec(paramClass, paramArrayOfByte1, paramArrayOfByte2, paramCall, paramCallback);
                return null;
            } catch (Throwable ex) {
                throw new HzTemplateException(ex);
            }
        }
    });
}

/**
 * {@inheritDoc}
 */
@Override
public <T extends Service, R> Map<byte[], R> coprocessorService(Class<T> protocol,
    byte[] startKey, byte[] endKey, Call<T, R> callable) throws IOException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  coprocessorService(protocol, startKey, endKey, callable, new Batch.Callback<R>() {
    public void update(byte[] region, byte[] row, R value) {
      results.put(region, value);
    }
  });
  return results;
}

/**
 * {@inheritDoc}
 */
@Override
public <T extends Service, R> Map<byte[], R> coprocessorService(Class<T> protocol,
    byte[] startKey, byte[] endKey, String[] clusterNames, Call<T, R> callable)
    throws IOException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  coprocessorService(protocol, startKey, endKey, clusterNames, callable, new Batch.Callback<R>() {
    public void update(byte[] region, byte[] row, R value) {
      results.put(region, value);
    }
  });
  return results;
}

/**
 * {@inheritDoc}
 */
@Override
public <T extends Service, R> void coprocessorService(final Class<T> protocol,
    final byte[] startKey, final byte[] endKey, final Call<T, R> callable,
    final Callback<R> callback) throws IOException, Throwable {
  coprocessorService(protocol, startKey, endKey, null, callable, callback);
}

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

@Override
public <T extends CoprocessorProtocol, R> Map<byte[], R> coprocessorExec(
        Class<T> protocol, byte[] startKey, byte[] endKey, Call<T, R> callable) throws IOException,
        Throwable {
    // TODO Auto-generated method stub
    return null;
}

@Override
public <T extends CoprocessorProtocol, R> void coprocessorExec(
        Class<T> protocol, byte[] startKey, byte[] endKey, Call<T, R> callable, Callback<R> callback)
        throws IOException, Throwable {
    // TODO Auto-generated method stub

}

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> type, byte[] bytes, byte[] bytes1, Call<T, R> call) throws ServiceException, Throwable {
  return wrappedTable.coprocessorService(type, bytes, bytes1, call);
}

@Override
public <T extends Service, R> void coprocessorService(Class<T> type, byte[] bytes, byte[] bytes1, Batch.Call<T, R> call, Batch.Callback<R> clbck) throws ServiceException, Throwable {
  wrappedTable.coprocessorService(type, bytes, bytes1, call, clbck);
}

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

@Override
public <T extends Service, R> void coprocessorService(Class<T> service, byte[] startKey,
    byte[] endKey, Call<T, R> callable, Callback<R> callback) throws Throwable {
  getTable().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();
}

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

@Override
public <T extends Service, R> Map<byte[], R> coprocessorService(Class<T> protocol,
    byte[] startKey, byte[] endKey, String[] clusterNames, Call<T, R> callable)
    throws IOException, Throwable {
  return table.coprocessorService(protocol, startKey, endKey, clusterNames, callable);
}

@Override
public <T extends Service, R> void coprocessorService(Class<T> protocol,
    byte[] startKey, byte[] endKey, String[] clusterNames, Call<T, R> callable,
    Callback<R> callback) throws IOException, Throwable {
  table.coprocessorService(protocol, startKey, endKey, clusterNames, callable, callback);
}

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
}

/**
 * 
 * Execute the coprocessor.
 * 
 * The cluster names will be considered as a filter condition together with the start key and stop
 * key.
 * 
 * @param protocol
 * @param startKey
 * @param endKey
 * @param clusterNames
 * @param callable
 * @return
 * @throws IOException
 * @throws Throwable
 */
public <T extends Service, R> Map<byte[], R> coprocessorService(Class<T> protocol,
    byte[] startKey, byte[] endKey, String[] clusterNames, Call<T, R> callable)
    throws IOException, Throwable;

/**
 * Execute the coprocessor.
 * 
 * The cluster names will be considered as a filter condition together with the start key and stop
 * key.
 * 
 * @param protocol
 * @param startKey
 * @param endKey
 * @param clusterNames
 * @param callable
 * @param callback
 * @throws IOException
 * @throws Throwable
 */
public <T extends Service, R> void coprocessorService(final Class<T> protocol,
    final byte[] startKey, final byte[] endKey, final String[] clusterNames,
    final Call<T, R> callable, final Callback<R> callback) throws IOException, Throwable;