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

项目:LCIndex-HBase-0.94.16    文件:ExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }

  if (row != null) {
    final Exec exec = new Exec(conf, row, protocol, method, args);
    ServerCallable<ExecResult> callable =
        new ServerCallable<ExecResult>(connection, table, row) {
          public ExecResult call() throws Exception {
            return server.execCoprocessor(location.getRegionInfo().getRegionName(),
                exec);
          }
        };
    ExecResult result = callable.withRetries();
    this.regionName = result.getRegionName();
    LOG.debug("Result is region="+ Bytes.toStringBinary(regionName) +
        ", value="+result.getValue());
    return result.getValue();
  }

  return null;
}
项目:IRIndex    文件:ExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }

  if (row != null) {
    final Exec exec = new Exec(conf, row, protocol, method, args);
    ServerCallable<ExecResult> callable =
        new ServerCallable<ExecResult>(connection, table, row) {
          public ExecResult call() throws Exception {
            return server.execCoprocessor(location.getRegionInfo().getRegionName(),
                exec);
          }
        };
    ExecResult result = callable.withRetries();
    this.regionName = result.getRegionName();
    LOG.debug("Result is region="+ Bytes.toStringBinary(regionName) +
        ", value="+result.getValue());
    return result.getValue();
  }

  return null;
}
项目:RStore    文件:ExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }

  if (row != null) {
    final Exec exec = new Exec(conf, row, protocol, method, args);
    ServerCallable<ExecResult> callable =
        new ServerCallable<ExecResult>(connection, table, row) {
          public ExecResult call() throws Exception {
            return server.execCoprocessor(location.getRegionInfo().getRegionName(),
                exec);
          }
        };
    ExecResult result = connection.getRegionServerWithRetries(callable);
    this.regionName = result.getRegionName();
    LOG.debug("Result is region="+ Bytes.toStringBinary(regionName) +
        ", value="+result.getValue());
    return result.getValue();
  }

  return null;
}
项目:HBase-Research    文件:ExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }

  if (row != null) {
    final Exec exec = new Exec(conf, row, protocol, method, args);
    ServerCallable<ExecResult> callable =
        new ServerCallable<ExecResult>(connection, table, row) {
          public ExecResult call() throws Exception {
            return server.execCoprocessor(location.getRegionInfo().getRegionName(),
                exec);
          }
        };
    ExecResult result = callable.withRetries();
    this.regionName = result.getRegionName();
    LOG.debug("Result is region="+ Bytes.toStringBinary(regionName) +
        ", value="+result.getValue());
    return result.getValue();
  }

  return null;
}
项目:hbase-0.94.8-qod    文件:ExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }

  if (row != null) {
    final Exec exec = new Exec(conf, row, protocol, method, args);
    ServerCallable<ExecResult> callable =
        new ServerCallable<ExecResult>(connection, table, row) {
          public ExecResult call() throws Exception {
            return server.execCoprocessor(location.getRegionInfo().getRegionName(),
                exec);
          }
        };
    ExecResult result = callable.withRetries();
    this.regionName = result.getRegionName();
    LOG.debug("Result is region="+ Bytes.toStringBinary(regionName) +
        ", value="+result.getValue());
    return result.getValue();
  }

  return null;
}
项目:hbase-0.94.8-qod    文件:ExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }

  if (row != null) {
    final Exec exec = new Exec(conf, row, protocol, method, args);
    ServerCallable<ExecResult> callable =
        new ServerCallable<ExecResult>(connection, table, row) {
          public ExecResult call() throws Exception {
            return server.execCoprocessor(location.getRegionInfo().getRegionName(),
                exec);
          }
        };
    ExecResult result = callable.withRetries();
    this.regionName = result.getRegionName();
    LOG.debug("Result is region="+ Bytes.toStringBinary(regionName) +
        ", value="+result.getValue());
    return result.getValue();
  }

  return null;
}
项目:hindex    文件:ExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }

  if (row != null) {
    final Exec exec = new Exec(conf, row, protocol, method, args);
    ServerCallable<ExecResult> callable =
        new ServerCallable<ExecResult>(connection, table, row) {
          public ExecResult call() throws Exception {
            return server.execCoprocessor(location.getRegionInfo().getRegionName(),
                exec);
          }
        };
    ExecResult result = callable.withRetries();
    this.regionName = result.getRegionName();
    LOG.debug("Result is region="+ Bytes.toStringBinary(regionName) +
        ", value="+result.getValue());
    return result.getValue();
  }

  return null;
}
项目:LCIndex-HBase-0.94.16    文件:MasterExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }
  Exec exec = new Exec(conf, protocol, method, args);
  ExecResult result = connection.getMaster().execCoprocessor(exec);
  LOG.debug("Master Result is value="+result.getValue());
  return result.getValue();
}
项目:IRIndex    文件:MasterExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }
  Exec exec = new Exec(conf, protocol, method, args);
  ExecResult result = connection.getMaster().execCoprocessor(exec);
  LOG.debug("Master Result is value="+result.getValue());
  return result.getValue();
}
项目:HBase-Research    文件:MasterExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }
  Exec exec = new Exec(conf, protocol, method, args);
  ExecResult result = connection.getMaster().execCoprocessor(exec);
  LOG.debug("Master Result is value="+result.getValue());
  return result.getValue();
}
项目:hbase-0.94.8-qod    文件:MasterExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }
  Exec exec = new Exec(conf, protocol, method, args);
  ExecResult result = connection.getMaster().execCoprocessor(exec);
  LOG.debug("Master Result is value="+result.getValue());
  return result.getValue();
}
项目:hbase-0.94.8-qod    文件:MasterExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }
  Exec exec = new Exec(conf, protocol, method, args);
  ExecResult result = connection.getMaster().execCoprocessor(exec);
  LOG.debug("Master Result is value="+result.getValue());
  return result.getValue();
}
项目:hindex    文件:MasterExecRPCInvoker.java   
@Override
public Object invoke(Object instance, final Method method, final Object[] args)
    throws Throwable {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Call: "+method.getName()+", "+(args != null ? args.length : 0));
  }
  Exec exec = new Exec(conf, protocol, method, args);
  ExecResult result = connection.getMaster().execCoprocessor(exec);
  LOG.debug("Master Result is value="+result.getValue());
  return result.getValue();
}
项目:LCIndex-HBase-0.94.16    文件:HRegionServer.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol} method using the
 * registered protocol handlers. {@link CoprocessorProtocol} implementations must be registered
 * per-region via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name, and parameters for
 *          the method invocation
 * @return an {@code ExecResult} instance containing the region name of the invocation and the
 *         return value
 * @throws IOException if no registered protocol handler is found or an error occurs during the
 *           invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class,
 *      org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
@Override
public ExecResult execCoprocessor(byte[] regionName, Exec call) throws IOException {
  checkOpen();
  requestCount.incrementAndGet();
  try {
    HRegion region = getRegion(regionName);
    return region.exec(call);
  } catch (Throwable t) {
    throw convertThrowableToIOE(cleanup(t));
  }
}
项目:IRIndex    文件:HRegionServer.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered per-region
 * via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
@Override
public ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException {
  checkOpen();
  requestCount.incrementAndGet();
  try {
    HRegion region = getRegion(regionName);
    return region.exec(call);
  } catch (Throwable t) {
    throw convertThrowableToIOE(cleanup(t));
  }
}
项目:RStore    文件:HRegionServer.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered per-region
 * via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
@Override
public ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException {
  checkOpen();
  requestCount.incrementAndGet();
  try {
    HRegion region = getRegion(regionName);
    return region.exec(call);
  } catch (Throwable t) {
    throw convertThrowableToIOE(cleanup(t));
  }
}
项目:HBase-Research    文件:HRegionServer.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered per-region
 * via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
@Override
public ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException {
  checkOpen();
  requestCount.incrementAndGet();
  try {
    HRegion region = getRegion(regionName);
    return region.exec(call);
  } catch (Throwable t) {
    throw convertThrowableToIOE(cleanup(t));
  }
}
项目:hbase-0.94.8-qod    文件:HRegionServer.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered per-region
 * via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
@Override
public ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException {
  checkOpen();
  requestCount.incrementAndGet();
  try {
    HRegion region = getRegion(regionName);
    return region.exec(call);
  } catch (Throwable t) {
    throw convertThrowableToIOE(cleanup(t));
  }
}
项目:hbase-0.94.8-qod    文件:HRegionServer.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered per-region
 * via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
@Override
public ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException {
  checkOpen();
  requestCount.incrementAndGet();
  try {
    HRegion region = getRegion(regionName);
    return region.exec(call);
  } catch (Throwable t) {
    throw convertThrowableToIOE(cleanup(t));
  }
}
项目:hindex    文件:HRegionServer.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered per-region
 * via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
@Override
public ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException {
  checkOpen();
  requestCount.incrementAndGet();
  try {
    HRegion region = getRegion(regionName);
    return region.exec(call);
  } catch (Throwable t) {
    throw convertThrowableToIOE(cleanup(t));
  }
}
项目:LCIndex-HBase-0.94.16    文件:HMasterInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)}
 * method before they are available.
 *
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)
 */
public ExecResult execCoprocessor(Exec call)
    throws IOException;
项目:LCIndex-HBase-0.94.16    文件:HRegionInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException;
项目:IRIndex    文件:HMasterInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)}
 * method before they are available.
 *
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)
 */
public ExecResult execCoprocessor(Exec call)
    throws IOException;
项目:IRIndex    文件:HRegionInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException;
项目:RStore    文件:HRegionInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException;
项目:HBase-Research    文件:HMasterInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)}
 * method before they are available.
 *
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)
 */
public ExecResult execCoprocessor(Exec call)
    throws IOException;
项目:HBase-Research    文件:HRegionInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException;
项目:hbase-0.94.8-qod    文件:HMasterInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)}
 * method before they are available.
 *
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)
 */
public ExecResult execCoprocessor(Exec call)
    throws IOException;
项目:hbase-0.94.8-qod    文件:HRegionInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException;
项目:hbase-0.94.8-qod    文件:HMasterInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)}
 * method before they are available.
 *
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)
 */
public ExecResult execCoprocessor(Exec call)
    throws IOException;
项目:hbase-0.94.8-qod    文件:HRegionInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException;
项目:hindex    文件:HMasterInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)}
 * method before they are available.
 *
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.master.MasterServices#registerProtocol(Class, CoprocessorProtocol)
 */
public ExecResult execCoprocessor(Exec call)
    throws IOException;
项目:hindex    文件:HRegionInterface.java   
/**
 * Executes a single {@link org.apache.hadoop.hbase.ipc.CoprocessorProtocol}
 * method using the registered protocol handlers.
 * {@link CoprocessorProtocol} implementations must be registered via the
 * {@link org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)}
 * method before they are available.
 *
 * @param regionName name of the region against which the invocation is executed
 * @param call an {@code Exec} instance identifying the protocol, method name,
 *     and parameters for the method invocation
 * @return an {@code ExecResult} instance containing the region name of the
 *     invocation and the return value
 * @throws IOException if no registered protocol handler is found or an error
 *     occurs during the invocation
 * @see org.apache.hadoop.hbase.regionserver.HRegion#registerProtocol(Class, org.apache.hadoop.hbase.ipc.CoprocessorProtocol)
 */
ExecResult execCoprocessor(byte[] regionName, Exec call)
    throws IOException;