import org.apache.hadoop.hbase.protobuf.generated.ErrorHandlingProtos.GenericExceptionMessage; //导入依赖的package包/类
/**
 * Converts a ForeignException to an array of bytes.
 * @param source the name of the external exception source
 * @param t the "local" external exception (local)
 * @return protobuf serialized version of ForeignException
 */
public static byte[] serialize(String source, Throwable t) {
  GenericExceptionMessage.Builder gemBuilder = GenericExceptionMessage.newBuilder();
  gemBuilder.setClassName(t.getClass().getName());
  if (t.getMessage() != null) {
    gemBuilder.setMessage(t.getMessage());
  }
  // set the stack trace, if there is one
  List<StackTraceElementMessage> stack =
      ForeignException.toStackTraceElementMessages(t.getStackTrace());
  if (stack != null) {
    gemBuilder.addAllTrace(stack);
  }
  GenericExceptionMessage payload = gemBuilder.build();
  ForeignExceptionMessage.Builder exception = ForeignExceptionMessage.newBuilder();
  exception.setGenericException(payload).setSource(source);
  ForeignExceptionMessage eem = exception.build();
  return eem.toByteArray();
}
 

import org.apache.hadoop.hbase.protobuf.generated.ErrorHandlingProtos.GenericExceptionMessage; //导入依赖的package包/类
public static ForeignExceptionMessage toProtoForeignException(String source, Throwable t) {
  GenericExceptionMessage.Builder gemBuilder = GenericExceptionMessage.newBuilder();
  gemBuilder.setClassName(t.getClass().getName());
  if (t.getMessage() != null) {
    gemBuilder.setMessage(t.getMessage());
  }
  // set the stack trace, if there is one
  List<StackTraceElementMessage> stack = toProtoStackTraceElement(t.getStackTrace());
  if (stack != null) {
    gemBuilder.addAllTrace(stack);
  }
  GenericExceptionMessage payload = gemBuilder.build();
  ForeignExceptionMessage.Builder exception = ForeignExceptionMessage.newBuilder();
  exception.setGenericException(payload).setSource(source);
  return exception.build();
}
 

import org.apache.hadoop.hbase.protobuf.generated.ErrorHandlingProtos.GenericExceptionMessage; //导入依赖的package包/类
/**
 * Takes a series of bytes and tries to generate an ForeignException instance for it.
 * @param bytes
 * @return the ForeignExcpetion instance
 * @throws InvalidProtocolBufferException if there was deserialization problem this is thrown.
 */
public static ForeignException deserialize(byte[] bytes) throws InvalidProtocolBufferException {
  // figure out the data we need to pass
  ForeignExceptionMessage eem = ForeignExceptionMessage.parseFrom(bytes);
  GenericExceptionMessage gem = eem.getGenericException();
  StackTraceElement [] trace = ForeignException.toStackTrace(gem.getTraceList());
  ProxyThrowable dfe = new ProxyThrowable(gem.getMessage(), trace);
  ForeignException e = new ForeignException(eem.getSource(), dfe);
  return e;
}
 

import org.apache.hadoop.hbase.protobuf.generated.ErrorHandlingProtos.GenericExceptionMessage; //导入依赖的package包/类
public static IOException toIOException(final ForeignExceptionMessage eem) {
  GenericExceptionMessage gem = eem.getGenericException();
  StackTraceElement[] trace = toStackTrace(gem.getTraceList());
  RemoteException re = new RemoteException(gem.getClassName(), gem.getMessage());
  re.setStackTrace(trace);
  return re.unwrapRemoteException();
}