Package org.apache.hadoop.hdfs.protocolPB

Class PBHelperClient

java.lang.Object
org.apache.hadoop.hdfs.protocolPB.PBHelperClient
public class PBHelperClient extends Object
Utilities for converting protobuf classes to and from hdfs-client side implementation classes and other helper utilities to help in dealing with protobuf. Note that when converting from an internal type to protobuf type, the converter never return null for protobuf type. The check for internal type being null must be done before calling the convert() method.

  • Method Details

    • getByteString

      public static org.apache.hadoop.thirdparty.protobuf.ByteString getByteString(byte[] bytes)

    • convert

      public static ShortCircuitShm.ShmId convert(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmIdProto shmId)

    • convert

      public static org.apache.hadoop.util.DataChecksum.Type convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ChecksumTypeProto type)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ChecksumTypeProto convert(org.apache.hadoop.util.DataChecksum.Type type)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockChecksumTypeProto convert(BlockChecksumType type)

    • convert

      public static BlockChecksumType convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockChecksumTypeProto blockChecksumTypeProto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockChecksumOptionsProto convert(BlockChecksumOptions options)

    • convert

      public static BlockChecksumOptions convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockChecksumOptionsProto options)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto convert(ExtendedBlock b)

    • convert

      public static org.apache.hadoop.security.proto.SecurityProtos.TokenProto convert(org.apache.hadoop.security.token.Token<?> tok)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmIdProto convert(ShortCircuitShm.ShmId shmId)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmSlotProto convert(ShortCircuitShm.SlotId slotId)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto convert(DatanodeID dn)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto.AdminState convert(DatanodeInfo.AdminStates inAs)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto convert(DatanodeInfo info)

    • convert

      public static List<? extends org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> convert(DatanodeInfo[] dnInfos)

    • convert

      public static List<? extends org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> convert(DatanodeInfo[] dnInfos, int startIdx)
      Copy from dnInfos to a target of list of same size starting at startIdx.

    • convert

      public static List<Boolean> convert(boolean[] targetPinnings, int idx)

    • convert

      public static List<String> convert(String[] targetIds, int idx)

    • convert

      public static ExtendedBlock convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto eb)

    • convert

      public static DatanodeLocalInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeLocalInfoProto proto)

    • convertDatanodeInfo

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto convertDatanodeInfo(DatanodeInfo di)

    • convertStorageType

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto convertStorageType(org.apache.hadoop.fs.StorageType type)

    • convertStorageType

      public static org.apache.hadoop.fs.StorageType convertStorageType(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto type)

    • convertStorageTypes

      public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> convertStorageTypes(org.apache.hadoop.fs.StorageType[] types)

    • convertStorageTypes

      public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> convertStorageTypes(org.apache.hadoop.fs.StorageType[] types, int startIdx)

    • vintPrefixed

      public static InputStream vintPrefixed(InputStream input) throws IOException
      Throws:
      IOException

    • convert

      public static org.apache.hadoop.crypto.CipherOption convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto proto)

    • convert

      public static org.apache.hadoop.crypto.CipherSuite convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherSuiteProto proto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto convert(org.apache.hadoop.crypto.CipherOption option)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherSuiteProto convert(org.apache.hadoop.crypto.CipherSuite suite)

    • convertCipherOptions

      public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto> convertCipherOptions(List<org.apache.hadoop.crypto.CipherOption> options)

    • convertCipherOptionProtos

      public static List<org.apache.hadoop.crypto.CipherOption> convertCipherOptionProtos(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto> protos)

    • convertLocatedBlockProto

      public static LocatedBlock convertLocatedBlockProto(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto proto)

    • convertTokens

      public static org.apache.hadoop.security.token.Token<BlockTokenIdentifier>[] convertTokens(List<org.apache.hadoop.security.proto.SecurityProtos.TokenProto> tokenProtos)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.AccessModeProto convert(BlockTokenIdentifier.AccessMode aMode)

    • convert

      public static BlockTokenIdentifier.AccessMode convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.AccessModeProto accessModeProto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockTokenSecretProto convert(BlockTokenIdentifier blockTokenSecret)

    • convert

      public static DatanodeInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto di)

    • convertStorageTypes

      public static org.apache.hadoop.fs.StorageType[] convertStorageTypes(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> storageTypesList, int expectedSize)

    • convert

      public static org.apache.hadoop.security.token.Token<BlockTokenIdentifier> convert(org.apache.hadoop.security.proto.SecurityProtos.TokenProto blockToken)

    • convert

      public static DatanodeID convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto dn)

    • convert

      public static DatanodeInfo.AdminStates convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto.AdminState adminState)

    • convert

      public static LocatedBlocks convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto lb)

    • convertStoragePolicies

      public static BlockStoragePolicy[] convertStoragePolicies(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto> policyProtos)

    • convert

      public static EventBatchList convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetEditsFromTxidResponseProto resp) throws IOException
      Throws:
      IOException

    • convertLocatedBlocks

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] convertLocatedBlocks(LocatedBlock[] lb)

    • convertLocatedBlocks

      public static LocatedBlock[] convertLocatedBlocks(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] lb)

    • convertLocatedBlocks

      public static List<LocatedBlock> convertLocatedBlocks(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> lb)

    • convertLocatedBlocks2

      public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> convertLocatedBlocks2(List<LocatedBlock> lb)

    • convertLocatedBlock

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto convertLocatedBlock(LocatedBlock b)

    • convert

      public static List<org.apache.hadoop.security.proto.SecurityProtos.TokenProto> convert(org.apache.hadoop.security.token.Token<BlockTokenIdentifier>[] blockTokens)

    • convertBlockIndices

      public static List<Integer> convertBlockIndices(byte[] blockIndices)

    • convertBlockIndices

      public static byte[] convertBlockIndices(List<Integer> blockIndices)

    • convert

      public static BlockStoragePolicy convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto proto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto.FsActionProto convert(org.apache.hadoop.fs.permission.FsAction v)

    • convertXAttrProto

      public static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto convertXAttrProto(XAttr a)

    • convert

      public static List<XAttr> convert(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.ListXAttrsResponseProto a)

    • convert

      public static List<XAttr> convert(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsResponseProto a)

    • convertXAttrs

      public static List<XAttr> convertXAttrs(List<org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto> xAttrSpec)

    • convertLocatedBlock

      public static List<LocatedBlock> convertLocatedBlock(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> lb)

    • convertAclEntry

      public static List<org.apache.hadoop.fs.permission.AclEntry> convertAclEntry(List<org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto> aclSpec)

    • convert

      public static org.apache.hadoop.fs.permission.FsAction convert(org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto.FsActionProto v)

    • convert

      public static org.apache.hadoop.fs.permission.FsPermission convert(org.apache.hadoop.hdfs.protocol.proto.AclProtos.FsPermissionProto p)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FileEncryptionInfoProto convert(org.apache.hadoop.fs.FileEncryptionInfo info)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto convert(org.apache.hadoop.crypto.CryptoProtocolVersion version)

    • convert

      public static org.apache.hadoop.fs.FileEncryptionInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FileEncryptionInfoProto proto)

    • convert

      public static org.apache.hadoop.crypto.CryptoProtocolVersion convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto proto)

    • convertXAttrProto

      public static List<org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto> convertXAttrProto(List<XAttr> xAttrSpec)

    • convert

      public static int convert(EnumSet<org.apache.hadoop.fs.XAttrSetFlag> flag)
      The flag field in PB is a bitmask whose values are the same a the emum values of XAttrSetFlag

    • convert

      public static EncryptionZone convert(org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.EncryptionZoneProto proto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesBatchResponseProto convert(OpenFileEntry openFileEntry)

    • convert

      public static OpenFileEntry convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesBatchResponseProto proto)

    • convert

      public static org.apache.hadoop.fs.permission.AclStatus convert(org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusResponseProto e)

    • convertAclEntryProto

      public static List<org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto> convertAclEntryProto(List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)

    • convert

      public static CachePoolEntry convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolEntryProto proto)

    • convert

      public static CachePoolInfo convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolInfoProto proto)

    • convert

      public static CachePoolStats convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolStatsProto proto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolInfoProto convert(CachePoolInfo info)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto convert(CacheDirectiveInfo info)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoExpirationProto convert(CacheDirectiveInfo.Expiration expiration)

    • convert

      public static CacheDirectiveEntry convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveEntryProto proto)

    • convert

      public static CacheDirectiveStats convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveStatsProto proto)

    • convert

      public static CacheDirectiveInfo convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto proto)

    • convert

      public static CacheDirectiveInfo.Expiration convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoExpirationProto proto)

    • convertCacheFlags

      public static int convertCacheFlags(EnumSet<CacheFlag> flags)

    • convert

      public static SnapshotDiffReport convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportProto reportProto)

    • convert

      public static SnapshotDiffReport.DiffReportEntry convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportEntryProto entry)

    • convert

      public static SnapshotDiffReportListing convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportListingProto reportProto)

    • convert

      public static SnapshotDiffReportListing.DiffReportListingEntry convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportListingEntryProto entry)

    • convert

      public static SnapshottableDirectoryStatus[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryListingProto sdlp)

    • convert

      public static SnapshottableDirectoryStatus convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryStatusProto sdirStatusProto)

    • convert

      public static SnapshotStatus[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotListingProto sdlp)

    • convert

      public static SnapshotStatus convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotStatusProto sdirStatusProto)

    • convert

      public static DataEncryptionKey convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DataEncryptionKeyProto bet)

    • convertDelegationToken

      public static org.apache.hadoop.security.token.Token<DelegationTokenIdentifier> convertDelegationToken(org.apache.hadoop.security.proto.SecurityProtos.TokenProto blockToken)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[] convert(DatanodeID[] did)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.AclProtos.FsPermissionProto convert(org.apache.hadoop.fs.permission.FsPermission p)

    • convert

      public static HdfsFileStatus convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto fs)

    • convert

      public static CorruptFileBlocks convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CorruptFileBlocksProto c)

    • convert

      public static org.apache.hadoop.fs.ContentSummary convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ContentSummaryProto cs)

    • convert

      public static org.apache.hadoop.fs.QuotaUsage convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.QuotaUsageProto qu)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.QuotaUsageProto convert(org.apache.hadoop.fs.QuotaUsage qu)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.ReencryptActionProto convert(HdfsConstants.ReencryptAction a)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeActionProto convert(HdfsConstants.RollingUpgradeAction a)

    • convert

      public static RollingUpgradeInfo convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeInfoProto proto)

    • convertDatanodeStorageReports

      public static DatanodeStorageReport[] convertDatanodeStorageReports(List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto> protos)

    • convertDatanodeStorageReport

      public static DatanodeStorageReport convertDatanodeStorageReport(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto proto)

    • convertStorageReports

      public static StorageReport[] convertStorageReports(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto> list)

    • convert

      public static StorageReport convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto p)

    • convert

      public static DatanodeStorage convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeStorageProto s)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.SafeModeActionProto convert(HdfsConstants.SafeModeAction a)

    • convert

      public static DatanodeInfo[] convert(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> list)

    • convert

      public static long[] convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsStatsResponseProto res)

    • convert

      public static ReplicatedBlockStats convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsReplicatedBlockStatsResponseProto res)

    • convert

      public static ECBlockGroupStats convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsECBlockGroupStatsResponseProto res)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeReportTypeProto convert(HdfsConstants.DatanodeReportType t)

    • convert

      public static DirectoryListing convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DirectoryListingProto dl)

    • convert

      public static HdfsFileStatus[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto[] fs)

    • convertHdfsFileStatus

      public static List<HdfsFileStatus> convertHdfsFileStatus(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto> fs)

    • convertCreateFlag

      public static int convertCreateFlag(org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> flag)

    • convert

      public static org.apache.hadoop.fs.FsServerDefaults convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsServerDefaultsProto fs)

    • convert

      public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto> convert(org.apache.hadoop.crypto.CryptoProtocolVersion[] versions)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto convert(BlockStoragePolicy policy)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypesProto convert(org.apache.hadoop.fs.StorageType[] types)

    • convert

      public static DatanodeID[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[] did)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto convert(Block b)

    • convert

      public static Block convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto b)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockTypeProto convert(BlockType blockType)

    • convert

      public static BlockType convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockTypeProto blockType)

    • convert

      public static DatanodeInfo[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto[] di)

    • convertDatanodeStorageReport

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto convertDatanodeStorageReport(DatanodeStorageReport report)

    • convertDatanodeStorageReports

      public static List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto> convertDatanodeStorageReports(DatanodeStorageReport[] reports)

    • convertLocatedBlock

      public static LocatedBlock[] convertLocatedBlock(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] lb)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto convert(LocatedBlocks lb)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DataEncryptionKeyProto convert(DataEncryptionKey bet)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsServerDefaultsProto convert(org.apache.hadoop.fs.FsServerDefaults fs)

    • convertCreateFlag

      public static org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> convertCreateFlag(int flag)

    • convertCacheFlags

      public static EnumSet<CacheFlag> convertCacheFlags(int flags)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto convert(HdfsFileStatus fs)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryStatusProto convert(SnapshottableDirectoryStatus status)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotStatusProto convert(SnapshotStatus status)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto[] convert(HdfsFileStatus[] fs)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DirectoryListingProto convert(DirectoryListing d)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsStatsResponseProto convert(long[] fsStats)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsReplicatedBlockStatsResponseProto convert(ReplicatedBlockStats replicatedBlockStats)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsECBlockGroupStatsResponseProto convert(ECBlockGroupStats ecBlockGroupStats)

    • convert

      public static HdfsConstants.DatanodeReportType convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeReportTypeProto t)

    • convert

      public static HdfsConstants.SafeModeAction convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.SafeModeActionProto a)

    • convert

      public static HdfsConstants.ReencryptAction convert(org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.ReencryptActionProto a)

    • convert

      public static HdfsConstants.RollingUpgradeAction convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeActionProto a)

    • convertRollingUpgradeStatus

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto convertRollingUpgradeStatus(RollingUpgradeStatus status)

    • convert

      public static RollingUpgradeStatus convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto proto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeInfoProto convert(RollingUpgradeInfo info)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CorruptFileBlocksProto convert(CorruptFileBlocks c)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ContentSummaryProto convert(org.apache.hadoop.fs.ContentSummary cs)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeStorageProto convert(DatanodeStorage s)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto convert(StorageReport r)

    • convertStorageReports

      public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto> convertStorageReports(StorageReport[] storages)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryListingProto convert(SnapshottableDirectoryStatus[] status)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotListingProto convert(SnapshotStatus[] status)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportEntryProto convert(SnapshotDiffReport.DiffReportEntry entry)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportListingEntryProto convert(SnapshotDiffReportListing.DiffReportListingEntry entry)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportListingProto convert(SnapshotDiffReportListing report)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportProto convert(SnapshotDiffReport report)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveStatsProto convert(CacheDirectiveStats stats)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveEntryProto convert(CacheDirectiveEntry entry)

    • convertBooleanList

      public static boolean[] convertBooleanList(List<Boolean> targetPinningsList)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolStatsProto convert(CachePoolStats stats)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolEntryProto convert(CachePoolEntry entry)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeLocalInfoProto convert(DatanodeLocalInfo info)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusResponseProto convert(org.apache.hadoop.fs.permission.AclStatus e)

    • convert

      public static EnumSet<org.apache.hadoop.fs.XAttrSetFlag> convert(int flag)

    • convertXAttr

      public static XAttr convertXAttr(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto a)

    • convertXAttrsResponse

      public static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsResponseProto convertXAttrsResponse(List<XAttr> xAttrs)

    • convertListXAttrsResponse

      public static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.ListXAttrsResponseProto convertListXAttrsResponse(List<XAttr> names)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.EncryptionZoneProto convert(EncryptionZone zone)

    • convert

      public static ShortCircuitShm.SlotId convert(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmSlotProto slotId)

    • convertEditsResponse

      public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetEditsFromTxidResponseProto convertEditsResponse(EventBatchList el)

    • convertCryptoProtocolVersions

      public static org.apache.hadoop.crypto.CryptoProtocolVersion[] convertCryptoProtocolVersions(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto> protos)

    • convertPerFileEncInfo

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.PerFileEncryptionInfoProto convertPerFileEncInfo(org.apache.hadoop.fs.FileEncryptionInfo info)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ZoneEncryptionInfoProto convert(org.apache.hadoop.crypto.CipherSuite suite, org.apache.hadoop.crypto.CryptoProtocolVersion version, String keyName)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ZoneEncryptionInfoProto convert(org.apache.hadoop.crypto.CipherSuite suite, org.apache.hadoop.crypto.CryptoProtocolVersion version, String keyName, org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ReencryptionInfoProto proto)

    • convert

      public static org.apache.hadoop.fs.FileEncryptionInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.PerFileEncryptionInfoProto fileProto, org.apache.hadoop.crypto.CipherSuite suite, org.apache.hadoop.crypto.CryptoProtocolVersion version, String keyName)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ReencryptionInfoProto convert(String ezkvn, Long submissionTime, boolean isCanceled, long numReencrypted, long numFailures, Long completionTime, String lastFile)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.ZoneReencryptionStatusProto convert(ZoneReencryptionStatus zs)

    • convert

      public static ZoneReencryptionStatus convert(org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.ZoneReencryptionStatusProto proto)

    • convert

      public static DatanodeInfo[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfosProto datanodeInfosProto)

    • convertECSchema

      public static org.apache.hadoop.io.erasurecode.ECSchema convertECSchema(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ECSchemaProto schema)

    • convertECSchema

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ECSchemaProto convertECSchema(org.apache.hadoop.io.erasurecode.ECSchema schema)

    • convertECState

      public static ErasureCodingPolicyState convertECState(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ErasureCodingPolicyState state)

    • convertECState

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ErasureCodingPolicyState convertECState(ErasureCodingPolicyState state)

    • convertErasureCodingPolicy

      public static ErasureCodingPolicy convertErasureCodingPolicy(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ErasureCodingPolicyProto proto)
      Convert the protobuf to a ErasureCodingPolicy.

    • convertErasureCodingPolicyInfo

      public static ErasureCodingPolicyInfo convertErasureCodingPolicyInfo(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ErasureCodingPolicyProto proto)
      Convert the protobuf to a ErasureCodingPolicyInfo. This should only be needed when the caller is interested in the state of the policy.

    • convertErasureCodingPolicy

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ErasureCodingPolicyProto convertErasureCodingPolicy(ErasureCodingPolicy policy)
      Convert a ErasureCodingPolicy to protobuf. This means no state of the policy will be set on the protobuf.

    • convertErasureCodingPolicy

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ErasureCodingPolicyProto convertErasureCodingPolicy(ErasureCodingPolicyInfo info)
      Convert a ErasureCodingPolicyInfo to protobuf. The protobuf will have the policy, and state. State is relevant when: 1. Persisting a policy to fsimage 2. Returning the policy to the RPC call DistributedFileSystem.getAllErasureCodingPolicies()

    • convertErasureCodingCodec

      public static org.apache.hadoop.hdfs.protocol.proto.ErasureCodingProtos.CodecProto convertErasureCodingCodec(String codec, String coders)

    • convertAddErasureCodingPolicyResponse

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.AddErasureCodingPolicyResponseProto convertAddErasureCodingPolicyResponse(AddErasureCodingPolicyResponse response)

    • convertAddErasureCodingPolicyResponse

      public static AddErasureCodingPolicyResponse convertAddErasureCodingPolicyResponse(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.AddErasureCodingPolicyResponseProto proto)

    • convertToProto

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfosProto convertToProto(DatanodeInfo[] datanodeInfos)

    • convertECTopologyVerifierResultProto

      public static ECTopologyVerifierResult convertECTopologyVerifierResultProto(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ECTopologyVerifierResultProto resp)

    • convertECTopologyVerifierResult

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ECTopologyVerifierResultProto convertECTopologyVerifierResult(ECTopologyVerifierResult resp)

    • convertAddBlockFlags

      public static EnumSet<AddBlockFlag> convertAddBlockFlags(List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlockFlagProto> addBlockFlags)

    • convertAddBlockFlags

      public static List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlockFlagProto> convertAddBlockFlags(EnumSet<AddBlockFlag> flags)

    • convert

      public static ProvidedStorageLocation convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ProvidedStorageLocationProto providedStorageLocationProto)

    • convert

      public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ProvidedStorageLocationProto convert(ProvidedStorageLocation providedStorageLocation)

    • convertOpenFileTypes

      public static EnumSet<OpenFilesIterator.OpenFilesType> convertOpenFileTypes(List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesTypeProto> openFilesTypeProtos)

    • convertOpenFileTypes

      public static List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesTypeProto> convertOpenFileTypes(EnumSet<OpenFilesIterator.OpenFilesType> types)