Package org.apache.hadoop.ozone.protocolPB

Interface RequestHandler

All Known Implementing Classes:
OzoneManagerRequestHandler
public interface RequestHandler
Handler to handleRequest the OmRequests.

  • Method Details

    • handleReadRequest

      org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse handleReadRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest request)
      Handle the read requests, and returns OmResponse.
      Parameters:
      request -
      Returns:
      OmResponse

    • validateRequest

      void validateRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest) throws org.apache.hadoop.ozone.om.exceptions.OMException
      Validates that the incoming OM request has required parameters. TODO: Add more validation checks before writing the request to Ratis log.
      Parameters:
      omRequest - client request to OM
      Throws:
      org.apache.hadoop.ozone.om.exceptions.OMException - thrown if required parameters are set to null.

    • handleWriteRequest

      default OMClientResponse handleWriteRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, ExecutionContext context, OzoneManagerDoubleBuffer ozoneManagerDoubleBuffer) throws IOException
      Handle write requests. In HA this will be called from OzoneManagerStateMachine applyTransaction method. In non-HA this will be called from OzoneManagerProtocolServerSideTranslatorPB.
      Parameters:
      omRequest - the write request
      context - - context containing ratis term index and index
      ozoneManagerDoubleBuffer - for adding response
      Returns:
      OMClientResponse
      Throws:
      IOException

    • handleWriteRequestImpl

      OMClientResponse handleWriteRequestImpl(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest omRequest, ExecutionContext context) throws IOException
      Implementation of handleWriteRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest, org.apache.hadoop.ozone.om.execution.flowcontrol.ExecutionContext, org.apache.hadoop.ozone.om.ratis.OzoneManagerDoubleBuffer).
      Parameters:
      omRequest - the write request
      context - - context containing ratis term index and index
      Returns:
      OMClientResponse
      Throws:
      IOException