Class OzoneManagerUtils

java.lang.Object
org.apache.hadoop.ozone.om.OzoneManagerUtils

public final class OzoneManagerUtils extends Object
Ozone Manager utility class.
  • Method Summary

    Modifier and Type
    Method
    Description
    static Map<String,String>
    buildTokenAuditMap(org.apache.hadoop.security.token.Token<org.apache.hadoop.ozone.security.OzoneTokenIdentifier> token)
    Builds an audit map based on the Delegation Token passed to the method.
    static org.apache.hadoop.ozone.om.helpers.OmBucketInfo
    getBucketInfo(org.apache.hadoop.ozone.om.OMMetadataManager metaMgr, String volName, String buckName)
    All the client requests are executed through OzoneManagerStateMachine#runCommand function and ensures sequential execution path.
    static org.apache.hadoop.ozone.om.helpers.BucketLayout
    getBucketLayout(org.apache.hadoop.ozone.om.OMMetadataManager metadataManager, String volName, String buckName)
    Get bucket layout for the given volume and bucket name.
    static org.apache.hadoop.ozone.om.helpers.OmBucketInfo
    getResolvedBucketInfo(org.apache.hadoop.ozone.om.OMMetadataManager metadataManager, String volName, String buckName)
    Get bucket info for the given volume and bucket name.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Method Details

    • getBucketInfo

      public static org.apache.hadoop.ozone.om.helpers.OmBucketInfo getBucketInfo(org.apache.hadoop.ozone.om.OMMetadataManager metaMgr, String volName, String buckName) throws IOException
      All the client requests are executed through OzoneManagerStateMachine#runCommand function and ensures sequential execution path. Below is the call trace to perform OM client request operation:
       
       OzoneManagerStateMachine#applyTransaction ->
       OzoneManagerStateMachine#runCommand ->
       OzoneManagerRequestHandler#handleWriteRequest ->
       OzoneManagerRatisUtils#createClientRequest ->
       BucketLayoutAwareOMKeyRequestFactory#createRequest ->
       ...
       OzoneManagerUtils#getBucketLayout ->
       OzoneManagerUtils#getOmBucketInfo ->
       omMetadataManager().getBucketTable().get(buckKey)
       
       
      Throws:
      IOException
    • getBucketLayout

      public static org.apache.hadoop.ozone.om.helpers.BucketLayout getBucketLayout(org.apache.hadoop.ozone.om.OMMetadataManager metadataManager, String volName, String buckName) throws IOException
      Get bucket layout for the given volume and bucket name.
      Parameters:
      metadataManager - OMMetadataManager
      volName - volume name
      buckName - bucket name
      Returns:
      bucket layout
      Throws:
      IOException
    • getResolvedBucketInfo

      public static org.apache.hadoop.ozone.om.helpers.OmBucketInfo getResolvedBucketInfo(org.apache.hadoop.ozone.om.OMMetadataManager metadataManager, String volName, String buckName) throws IOException
      Get bucket info for the given volume and bucket name.
      Parameters:
      metadataManager - metadata manager
      volName - volume name
      buckName - bucket name
      Returns:
      bucket info
      Throws:
      IOException
    • buildTokenAuditMap

      public static Map<String,String> buildTokenAuditMap(org.apache.hadoop.security.token.Token<org.apache.hadoop.ozone.security.OzoneTokenIdentifier> token)
      Builds an audit map based on the Delegation Token passed to the method.
      Parameters:
      token - Delegation Token
      Returns:
      AuditMap