Java 类org.apache.hadoop.hbase.protobuf.generated.AdminProtos.RollWALWriterRequest 实例源码

/**
 * Roll the WAL writer of the region server.
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public RollWALWriterResponse rollWALWriter(final RpcController controller,
    final RollWALWriterRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    regionServer.getRegionServerCoprocessorHost().preRollWALWriterRequest();
    regionServer.walRoller.requestRollAll();
    regionServer.getRegionServerCoprocessorHost().postRollWALWriterRequest();
    RollWALWriterResponse.Builder builder = RollWALWriterResponse.newBuilder();
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
 * Roll the WAL writer of the region server.
 *
 * @param controller the RPC controller
 * @param request    the request
 * @throws ServiceException
 */
@Override
public RollWALWriterResponse rollWALWriter(final RpcController controller,
                                           final RollWALWriterRequest request) throws ServiceException {
    try {
        checkOpen();
        requestCount.increment();
        regionServer.getRegionServerCoprocessorHost().preRollWALWriterRequest();
        regionServer.walRoller.requestRollAll();
        regionServer.getRegionServerCoprocessorHost().postRollWALWriterRequest();
        RollWALWriterResponse.Builder builder = RollWALWriterResponse.newBuilder();
        return builder.build();
    } catch (IOException ie) {
        throw new ServiceException(ie);
    }
}

/**
 * Roll the WAL writer of the region server.
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public RollWALWriterResponse rollWALWriter(final RpcController controller,
    final RollWALWriterRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HLog wal = this.getWAL();
    byte[][] regionsToFlush = wal.rollWriter(true);
    RollWALWriterResponse.Builder builder = RollWALWriterResponse.newBuilder();
    if (regionsToFlush != null) {
      for (byte[] region: regionsToFlush) {
        builder.addRegionToFlush(HBaseZeroCopyByteString.wrap(region));
      }
    }
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
  * Roll the log writer. That is, start writing log messages to a new file.
  *
  * @param serverName
  *          The servername of the regionserver. A server name is made of host,
  *          port and startcode. This is mandatory. Here is an example:
  *          <code> host187.example.com,60020,1289493121758</code>
  * @return If lots of logs, flush the returned regions so next time through
  * we can clean logs. Returns null if nothing to flush.  Names are actual
  * region names as returned by {@link HRegionInfo#getEncodedName()}
  * @throws IOException if a remote or network exception occurs
  * @throws FailedLogCloseException
  */
public synchronized  byte[][] rollHLogWriter(String serverName)
     throws IOException, FailedLogCloseException {
   ServerName sn = ServerName.valueOf(serverName);
   AdminService.BlockingInterface admin = this.connection.getAdmin(sn);
   RollWALWriterRequest request = RequestConverter.buildRollWALWriterRequest();
   try {
     RollWALWriterResponse response = admin.rollWALWriter(null, request);
     int regionCount = response.getRegionToFlushCount();
     byte[][] regionsToFlush = new byte[regionCount][];
     for (int i = 0; i < regionCount; i++) {
       ByteString region = response.getRegionToFlush(i);
       regionsToFlush[i] = region.toByteArray();
     }
     return regionsToFlush;
   } catch (ServiceException se) {
     throw ProtobufUtil.getRemoteException(se);
   }
 }

/**
 * Roll the WAL writer of the region server.
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public RollWALWriterResponse rollWALWriter(final RpcController controller,
    final RollWALWriterRequest request) throws ServiceException {
  try {
    checkOpen();
    requestCount.increment();
    HLog wal = regionServer.getWAL();
    byte[][] regionsToFlush = wal.rollWriter(true);
    RollWALWriterResponse.Builder builder = RollWALWriterResponse.newBuilder();
    if (regionsToFlush != null) {
      for (byte[] region: regionsToFlush) {
        builder.addRegionToFlush(HBaseZeroCopyByteString.wrap(region));
      }
    }
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
  * Roll the log writer. That is, start writing log messages to a new file.
  *
  * @param serverName
  *          The servername of the regionserver. A server name is made of host,
  *          port and startcode. This is mandatory. Here is an example:
  *          <code> host187.example.com,60020,1289493121758</code>
  * @return If lots of logs, flush the returned regions so next time through
  * we can clean logs. Returns null if nothing to flush.  Names are actual
  * region names as returned by {@link HRegionInfo#getEncodedName()}
  * @throws IOException if a remote or network exception occurs
  * @throws FailedLogCloseException
  */
public synchronized  byte[][] rollHLogWriter(String serverName)
     throws IOException, FailedLogCloseException {
   ServerName sn = ServerName.valueOf(serverName);
   AdminService.BlockingInterface admin = this.connection.getAdmin(sn);
   RollWALWriterRequest request = RequestConverter.buildRollWALWriterRequest();
   try {
     RollWALWriterResponse response = admin.rollWALWriter(null, request);
     int regionCount = response.getRegionToFlushCount();
     byte[][] regionsToFlush = new byte[regionCount][];
     for (int i = 0; i < regionCount; i++) {
       ByteString region = response.getRegionToFlush(i);
       regionsToFlush[i] = region.toByteArray();
     }
     return regionsToFlush;
   } catch (ServiceException se) {
     throw ProtobufUtil.getRemoteException(se);
   }
 }

/**
 * Roll the WAL writer of the region server.
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public RollWALWriterResponse rollWALWriter(final RpcController controller,
    final RollWALWriterRequest request) throws ServiceException {
  try {
    requestCount.increment();
    HLog wal = this.getWAL();
    byte[][] regionsToFlush = wal.rollWriter(true);
    RollWALWriterResponse.Builder builder = RollWALWriterResponse.newBuilder();
    if (regionsToFlush != null) {
      for (byte[] region: regionsToFlush) {
        builder.addRegionToFlush(ZeroCopyLiteralByteString.wrap(region));
      }
    }
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

/**
  * Roll the log writer. That is, start writing log messages to a new file.
  *
  * @param serverName
  *          The servername of the regionserver. A server name is made of host,
  *          port and startcode. This is mandatory. Here is an example:
  *          <code> host187.example.com,60020,1289493121758</code>
  * @return If lots of logs, flush the returned regions so next time through
  * we can clean logs. Returns null if nothing to flush.  Names are actual
  * region names as returned by {@link HRegionInfo#getEncodedName()}
  * @throws IOException if a remote or network exception occurs
  * @throws FailedLogCloseException
  */
public synchronized  byte[][] rollHLogWriter(String serverName)
     throws IOException, FailedLogCloseException {
   ServerName sn = ServerName.valueOf(serverName);
   AdminService.BlockingInterface admin = this.connection.getAdmin(sn);
   RollWALWriterRequest request = RequestConverter.buildRollWALWriterRequest();
   try {
     RollWALWriterResponse response = admin.rollWALWriter(null, request);
     int regionCount = response.getRegionToFlushCount();
     byte[][] regionsToFlush = new byte[regionCount][];
     for (int i = 0; i < regionCount; i++) {
       ByteString region = response.getRegionToFlush(i);
       regionsToFlush[i] = region.toByteArray();
     }
     return regionsToFlush;
   } catch (ServiceException se) {
     throw ProtobufUtil.getRemoteException(se);
   }
 }

/**
  * Roll the log writer. That is, start writing log messages to a new file.
  *
  * @param serverName
  *          The servername of the regionserver. A server name is made of host,
  *          port and startcode. This is mandatory. Here is an example:
  *          <code> host187.example.com,60020,1289493121758</code>
  * @return If lots of logs, flush the returned regions so next time through
  * we can clean logs. Returns null if nothing to flush.  Names are actual
  * region names as returned by {@link HRegionInfo#getEncodedName()}
  * @throws IOException if a remote or network exception occurs
  * @throws FailedLogCloseException
  */
public synchronized  byte[][] rollHLogWriter(String serverName)
     throws IOException, FailedLogCloseException {
   ServerName sn = new ServerName(serverName);
   AdminProtocol admin = this.connection.getAdmin(
       sn.getHostname(), sn.getPort());
   RollWALWriterRequest request = RequestConverter.buildRollWALWriterRequest();;
   try {
     RollWALWriterResponse response = admin.rollWALWriter(null, request);
     int regionCount = response.getRegionToFlushCount();
     byte[][] regionsToFlush = new byte[regionCount][];
     for (int i = 0; i < regionCount; i++) {
       ByteString region = response.getRegionToFlush(i);
       regionsToFlush[i] = region.toByteArray();
     }
     return regionsToFlush;
   } catch (ServiceException se) {
     throw ProtobufUtil.getRemoteException(se);
   }
 }

/**
 * Roll the WAL writer of the region server.
 *
 * @param controller the RPC controller
 * @param request the request
 * @throws ServiceException
 */
@Override
public RollWALWriterResponse rollWALWriter(final RpcController controller,
    final RollWALWriterRequest request) throws ServiceException {
  try {
    requestCount.increment();
    HLog wal = this.getWAL();
    byte[][] regionsToFlush = wal.rollWriter(true);
    RollWALWriterResponse.Builder builder = RollWALWriterResponse.newBuilder();
    if (regionsToFlush != null) {
      for (byte[] region: regionsToFlush) {
        builder.addRegionToFlush(ByteString.copyFrom(region));
      }
    }
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}

private RollWALWriterResponse rollWALWriterImpl(final ServerName sn) throws IOException,
    FailedLogCloseException {
  AdminService.BlockingInterface admin = this.connection.getAdmin(sn);
  RollWALWriterRequest request = RequestConverter.buildRollWALWriterRequest();
  PayloadCarryingRpcController controller = rpcControllerFactory.newController();

  try {
    // TODO: this does not do retries, it should. Set priority and timeout in controller
    return admin.rollWALWriter(controller, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

private RollWALWriterResponse rollWALWriterImpl(final ServerName sn) throws IOException,
    FailedLogCloseException {
  AdminService.BlockingInterface admin = this.connection.getAdmin(sn);
  RollWALWriterRequest request = RequestConverter.buildRollWALWriterRequest();
  try {
    return admin.rollWALWriter(null, request);
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}

@Override
public RollWALWriterResponse rollWALWriter(RpcController controller,
    RollWALWriterRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public RollWALWriterResponse rollWALWriter(RpcController controller,
    RollWALWriterRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public RollWALWriterResponse rollWALWriter(RpcController controller,
    RollWALWriterRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public RollWALWriterResponse rollWALWriter(RpcController controller,
    RollWALWriterRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public RollWALWriterResponse rollWALWriter(RpcController controller,
    RollWALWriterRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

@Override
public RollWALWriterResponse rollWALWriter(RpcController controller,
    RollWALWriterRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}

/**
 * Create a new RollWALWriterRequest
 *
 * @return a ReplicateWALEntryRequest
 */
public static RollWALWriterRequest buildRollWALWriterRequest() {
  return ROLL_WAL_WRITER_REQUEST;
}

/**
 * Create a new RollWALWriterRequest
 *
 * @return a ReplicateWALEntryRequest
 */
public static RollWALWriterRequest buildRollWALWriterRequest() {
  return ROLL_WAL_WRITER_REQUEST;
}

/**
 * Create a new RollWALWriterRequest
 *
 * @return a ReplicateWALEntryRequest
 */
public static RollWALWriterRequest buildRollWALWriterRequest() {
  return ROLL_WAL_WRITER_REQUEST;
}

/**
 * Create a new RollWALWriterRequest
 *
 * @return a ReplicateWALEntryRequest
 */
public static RollWALWriterRequest buildRollWALWriterRequest() {
  return ROLL_WAL_WRITER_REQUEST;
}

/**
 * Create a new RollWALWriterRequest
 *
 * @return a ReplicateWALEntryRequest
 */
public static RollWALWriterRequest buildRollWALWriterRequest() {
  return ROLL_WAL_WRITER_REQUEST;
}

/**
 * Create a new RollWALWriterRequest
 *
 * @return a ReplicateWALEntryRequest
 */
public static RollWALWriterRequest buildRollWALWriterRequest() {
  RollWALWriterRequest.Builder builder = RollWALWriterRequest.newBuilder();
  return builder.build();
}