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;