public class PBHelperClient extends Object
| Modifier and Type | Method and Description |
|---|---|
static org.apache.hadoop.fs.permission.FsAction |
convert(org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto.FsActionProto v) |
static org.apache.hadoop.fs.permission.AclStatus |
convert(org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusResponseProto e) |
static org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusResponseProto |
convert(org.apache.hadoop.fs.permission.AclStatus e) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto |
convert(org.apache.hadoop.hdfs.protocol.Block b) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto |
convert(org.apache.hadoop.hdfs.protocol.BlockStoragePolicy policy) |
static List<Boolean> |
convert(boolean[] targetPinnings,
int idx) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveEntryProto |
convert(CacheDirectiveEntry entry) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoExpirationProto |
convert(CacheDirectiveInfo.Expiration expiration) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto |
convert(CacheDirectiveInfo info) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveStatsProto |
convert(CacheDirectiveStats stats) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolEntryProto |
convert(CachePoolEntry entry) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolInfoProto |
convert(CachePoolInfo info) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolStatsProto |
convert(CachePoolStats stats) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto |
convert(org.apache.hadoop.crypto.CipherOption option) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherSuiteProto |
convert(org.apache.hadoop.crypto.CipherSuite suite) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ZoneEncryptionInfoProto |
convert(org.apache.hadoop.crypto.CipherSuite suite,
org.apache.hadoop.crypto.CryptoProtocolVersion version,
String keyName) |
static CacheDirectiveEntry |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveEntryProto proto) |
static CacheDirectiveInfo.Expiration |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoExpirationProto proto) |
static CacheDirectiveInfo |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto proto) |
static CacheDirectiveStats |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveStatsProto proto) |
static CachePoolEntry |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolEntryProto proto) |
static CachePoolInfo |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolInfoProto proto) |
static CachePoolStats |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolStatsProto proto) |
static HdfsConstants.DatanodeReportType |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeReportTypeProto t) |
static org.apache.hadoop.hdfs.inotify.EventBatchList |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetEditsFromTxidResponseProto resp) |
static long[] |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsStatsResponseProto res) |
static org.apache.hadoop.hdfs.protocol.OpenFileEntry |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesBatchResponseProto proto) |
static HdfsConstants.RollingUpgradeAction |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeActionProto a) |
static org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeInfoProto proto) |
static HdfsConstants.SafeModeAction |
convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.SafeModeActionProto a) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ContentSummaryProto |
convert(org.apache.hadoop.fs.ContentSummary cs) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CorruptFileBlocksProto |
convert(CorruptFileBlocks c) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto |
convert(org.apache.hadoop.crypto.CryptoProtocolVersion version) |
static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto> |
convert(org.apache.hadoop.crypto.CryptoProtocolVersion[] versions) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ChecksumTypeProto |
convert(org.apache.hadoop.util.DataChecksum.Type type) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DataEncryptionKeyProto |
convert(org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey bet) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto |
convert(org.apache.hadoop.hdfs.protocol.DatanodeID dn) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[] |
convert(org.apache.hadoop.hdfs.protocol.DatanodeID[] did) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto.AdminState |
convert(DatanodeInfo.AdminStates inAs) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto |
convert(org.apache.hadoop.hdfs.protocol.DatanodeInfo info) |
static List<? extends org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> |
convert(org.apache.hadoop.hdfs.protocol.DatanodeInfo[] dnInfos) |
static List<? extends org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> |
convert(org.apache.hadoop.hdfs.protocol.DatanodeInfo[] dnInfos,
int startIdx)
Copy from
dnInfos to a target of list of same size starting at
startIdx. |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeLocalInfoProto |
convert(org.apache.hadoop.hdfs.protocol.DatanodeLocalInfo info) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeStorageProto |
convert(DatanodeStorage s) |
static ShortCircuitShm.ShmId |
convert(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmIdProto shmId) |
static ShortCircuitShm.SlotId |
convert(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmSlotProto slotId) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DirectoryListingProto |
convert(org.apache.hadoop.hdfs.protocol.DirectoryListing d) |
static org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.EncryptionZoneProto |
convert(EncryptionZone zone) |
static EncryptionZone |
convert(org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.EncryptionZoneProto proto) |
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
|
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto |
convert(org.apache.hadoop.hdfs.protocol.ExtendedBlock b) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FileEncryptionInfoProto |
convert(org.apache.hadoop.fs.FileEncryptionInfo info) |
static org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto.FsActionProto |
convert(org.apache.hadoop.fs.permission.FsAction v) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsPermissionProto |
convert(org.apache.hadoop.fs.permission.FsPermission p) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsServerDefaultsProto |
convert(org.apache.hadoop.fs.FsServerDefaults fs) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeReportTypeProto |
convert(HdfsConstants.DatanodeReportType t) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeActionProto |
convert(HdfsConstants.RollingUpgradeAction a) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.SafeModeActionProto |
convert(HdfsConstants.SafeModeAction a) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto |
convert(org.apache.hadoop.hdfs.protocol.HdfsFileStatus fs) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto[] |
convert(org.apache.hadoop.hdfs.protocol.HdfsFileStatus[] fs) |
static org.apache.hadoop.hdfs.protocol.Block |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto b) |
static org.apache.hadoop.hdfs.protocol.BlockStoragePolicy |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto proto) |
static org.apache.hadoop.util.DataChecksum.Type |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ChecksumTypeProto type) |
static org.apache.hadoop.crypto.CipherOption |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto proto) |
static org.apache.hadoop.crypto.CipherSuite |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherSuiteProto proto) |
static org.apache.hadoop.fs.ContentSummary |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ContentSummaryProto cs) |
static CorruptFileBlocks |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CorruptFileBlocksProto c) |
static org.apache.hadoop.crypto.CryptoProtocolVersion |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto proto) |
static org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DataEncryptionKeyProto bet) |
static org.apache.hadoop.hdfs.protocol.DatanodeID |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto dn) |
static org.apache.hadoop.hdfs.protocol.DatanodeID[] |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[] did) |
static DatanodeInfo.AdminStates |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto.AdminState adminState) |
static org.apache.hadoop.hdfs.protocol.DatanodeInfo |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto di) |
static org.apache.hadoop.hdfs.protocol.DatanodeInfo[] |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto[] di) |
static org.apache.hadoop.hdfs.protocol.DatanodeInfo[] |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfosProto datanodeInfosProto) |
static org.apache.hadoop.hdfs.protocol.DatanodeLocalInfo |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeLocalInfoProto proto) |
static DatanodeStorage |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeStorageProto s) |
static org.apache.hadoop.hdfs.protocol.DirectoryListing |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DirectoryListingProto dl) |
static org.apache.hadoop.hdfs.protocol.ExtendedBlock |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto eb) |
static org.apache.hadoop.fs.FileEncryptionInfo |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FileEncryptionInfoProto proto) |
static org.apache.hadoop.fs.permission.FsPermission |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsPermissionProto p) |
static org.apache.hadoop.fs.FsServerDefaults |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsServerDefaultsProto fs) |
static org.apache.hadoop.hdfs.protocol.HdfsFileStatus |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto fs) |
static org.apache.hadoop.hdfs.protocol.HdfsFileStatus[] |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto[] fs) |
static org.apache.hadoop.hdfs.protocol.LocatedBlock |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto proto) |
static org.apache.hadoop.hdfs.protocol.LocatedBlocks |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto lb) |
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) |
static org.apache.hadoop.fs.QuotaUsage |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.QuotaUsageProto qu) |
static org.apache.hadoop.hdfs.protocol.RollingUpgradeStatus |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto proto) |
static SnapshotDiffReport.DiffReportEntry |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportEntryProto entry) |
static SnapshotDiffReport |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportProto reportProto) |
static SnapshottableDirectoryStatus[] |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryListingProto sdlp) |
static SnapshottableDirectoryStatus |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryStatusProto sdirStatusProto) |
static StorageReport |
convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto p) |
static EnumSet<org.apache.hadoop.fs.XAttrSetFlag> |
convert(int flag) |
static org.apache.hadoop.hdfs.protocol.DatanodeInfo[] |
convert(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> list) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto |
convert(org.apache.hadoop.hdfs.protocol.LocatedBlock b) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto |
convert(org.apache.hadoop.hdfs.protocol.LocatedBlocks lb) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsStatsResponseProto |
convert(long[] fsStats) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesBatchResponseProto |
convert(org.apache.hadoop.hdfs.protocol.OpenFileEntry openFileEntry) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.QuotaUsageProto |
convert(org.apache.hadoop.fs.QuotaUsage qu) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeInfoProto |
convert(org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo info) |
static org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> |
convert(org.apache.hadoop.security.proto.SecurityProtos.TokenProto blockToken) |
static org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmIdProto |
convert(ShortCircuitShm.ShmId shmId) |
static org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmSlotProto |
convert(ShortCircuitShm.SlotId slotId) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportEntryProto |
convert(SnapshotDiffReport.DiffReportEntry entry) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportProto |
convert(SnapshotDiffReport report) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryStatusProto |
convert(SnapshottableDirectoryStatus status) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryListingProto |
convert(SnapshottableDirectoryStatus[] status) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto |
convert(StorageReport r) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypesProto |
convert(org.apache.hadoop.fs.StorageType[] types) |
static org.apache.hadoop.security.proto.SecurityProtos.TokenProto |
convert(org.apache.hadoop.security.token.Token<?> tok) |
static List<org.apache.hadoop.fs.XAttr> |
convert(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsResponseProto a) |
static List<org.apache.hadoop.fs.XAttr> |
convert(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.ListXAttrsResponseProto a) |
static List<org.apache.hadoop.fs.permission.AclEntry> |
convertAclEntry(List<org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto> aclSpec) |
static List<org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto> |
convertAclEntryProto(List<org.apache.hadoop.fs.permission.AclEntry> aclSpec) |
static List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlockFlagProto> |
convertAddBlockFlags(EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags) |
static EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> |
convertAddBlockFlags(List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlockFlagProto> addBlockFlags) |
static boolean[] |
convertBooleanList(List<Boolean> targetPinningsList) |
static int |
convertCacheFlags(EnumSet<CacheFlag> flags) |
static EnumSet<CacheFlag> |
convertCacheFlags(int flags) |
static List<org.apache.hadoop.crypto.CipherOption> |
convertCipherOptionProtos(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto> protos) |
static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto> |
convertCipherOptions(List<org.apache.hadoop.crypto.CipherOption> options) |
static int |
convertCreateFlag(org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> flag) |
static org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> |
convertCreateFlag(int flag) |
static org.apache.hadoop.crypto.CryptoProtocolVersion[] |
convertCryptoProtocolVersions(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto> protos) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto |
convertDatanodeInfo(org.apache.hadoop.hdfs.protocol.DatanodeInfo di) |
static DatanodeStorageReport |
convertDatanodeStorageReport(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto proto) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto |
convertDatanodeStorageReport(DatanodeStorageReport report) |
static List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto> |
convertDatanodeStorageReports(DatanodeStorageReport[] reports) |
static DatanodeStorageReport[] |
convertDatanodeStorageReports(List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto> protos) |
static org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier> |
convertDelegationToken(org.apache.hadoop.security.proto.SecurityProtos.TokenProto blockToken) |
static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetEditsFromTxidResponseProto |
convertEditsResponse(org.apache.hadoop.hdfs.inotify.EventBatchList el) |
static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.ListXAttrsResponseProto |
convertListXAttrsResponse(List<org.apache.hadoop.fs.XAttr> names) |
static org.apache.hadoop.hdfs.protocol.LocatedBlock[] |
convertLocatedBlock(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] lb) |
static List<org.apache.hadoop.hdfs.protocol.LocatedBlock> |
convertLocatedBlock(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> lb) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] |
convertLocatedBlock(org.apache.hadoop.hdfs.protocol.LocatedBlock[] lb) |
static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> |
convertLocatedBlock2(List<org.apache.hadoop.hdfs.protocol.LocatedBlock> lb) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.PerFileEncryptionInfoProto |
convertPerFileEncInfo(org.apache.hadoop.fs.FileEncryptionInfo info) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto |
convertRollingUpgradeStatus(org.apache.hadoop.hdfs.protocol.RollingUpgradeStatus status) |
static org.apache.hadoop.hdfs.protocol.BlockStoragePolicy[] |
convertStoragePolicies(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto> policyProtos) |
static StorageReport[] |
convertStorageReports(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto> list) |
static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto> |
convertStorageReports(StorageReport[] storages) |
static org.apache.hadoop.fs.StorageType |
convertStorageType(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto type) |
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto |
convertStorageType(org.apache.hadoop.fs.StorageType type) |
static org.apache.hadoop.fs.StorageType[] |
convertStorageTypes(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> storageTypesList,
int expectedSize) |
static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> |
convertStorageTypes(org.apache.hadoop.fs.StorageType[] types) |
static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> |
convertStorageTypes(org.apache.hadoop.fs.StorageType[] types,
int startIdx) |
static org.apache.hadoop.fs.XAttr |
convertXAttr(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto a) |
static List<org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto> |
convertXAttrProto(List<org.apache.hadoop.fs.XAttr> xAttrSpec) |
static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto |
convertXAttrProto(org.apache.hadoop.fs.XAttr a) |
static List<org.apache.hadoop.fs.XAttr> |
convertXAttrs(List<org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto> xAttrSpec) |
static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsResponseProto |
convertXAttrsResponse(List<org.apache.hadoop.fs.XAttr> xAttrs) |
static com.google.protobuf.ByteString |
getByteString(byte[] bytes) |
static InputStream |
vintPrefixed(InputStream input) |
public static com.google.protobuf.ByteString getByteString(byte[] bytes)
public static ShortCircuitShm.ShmId convert(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmIdProto shmId)
public static org.apache.hadoop.util.DataChecksum.Type convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ChecksumTypeProto type)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ChecksumTypeProto convert(org.apache.hadoop.util.DataChecksum.Type type)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto convert(org.apache.hadoop.hdfs.protocol.ExtendedBlock b)
public static org.apache.hadoop.security.proto.SecurityProtos.TokenProto convert(org.apache.hadoop.security.token.Token<?> tok)
public static org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmIdProto convert(ShortCircuitShm.ShmId shmId)
public static org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmSlotProto convert(ShortCircuitShm.SlotId slotId)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto convert(org.apache.hadoop.hdfs.protocol.DatanodeID dn)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto.AdminState convert(DatanodeInfo.AdminStates inAs)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto convert(org.apache.hadoop.hdfs.protocol.DatanodeInfo info)
public static List<? extends org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> convert(org.apache.hadoop.hdfs.protocol.DatanodeInfo[] dnInfos)
public static List<? extends org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> convert(org.apache.hadoop.hdfs.protocol.DatanodeInfo[] dnInfos, int startIdx)
dnInfos to a target of list of same size starting at
startIdx.public static org.apache.hadoop.hdfs.protocol.ExtendedBlock convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ExtendedBlockProto eb)
public static org.apache.hadoop.hdfs.protocol.DatanodeLocalInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeLocalInfoProto proto)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto convertDatanodeInfo(org.apache.hadoop.hdfs.protocol.DatanodeInfo di)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto convertStorageType(org.apache.hadoop.fs.StorageType type)
public static org.apache.hadoop.fs.StorageType convertStorageType(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto type)
public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> convertStorageTypes(org.apache.hadoop.fs.StorageType[] types)
public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> convertStorageTypes(org.apache.hadoop.fs.StorageType[] types, int startIdx)
public static InputStream vintPrefixed(InputStream input) throws IOException
IOExceptionpublic static org.apache.hadoop.crypto.CipherOption convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto proto)
public static org.apache.hadoop.crypto.CipherSuite convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherSuiteProto proto)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto convert(org.apache.hadoop.crypto.CipherOption option)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherSuiteProto convert(org.apache.hadoop.crypto.CipherSuite suite)
public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto> convertCipherOptions(List<org.apache.hadoop.crypto.CipherOption> options)
public static List<org.apache.hadoop.crypto.CipherOption> convertCipherOptionProtos(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CipherOptionProto> protos)
public static org.apache.hadoop.hdfs.protocol.LocatedBlock convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto proto)
public static org.apache.hadoop.hdfs.protocol.DatanodeInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto di)
public static org.apache.hadoop.fs.StorageType[] convertStorageTypes(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypeProto> storageTypesList, int expectedSize)
public static org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> convert(org.apache.hadoop.security.proto.SecurityProtos.TokenProto blockToken)
public static org.apache.hadoop.hdfs.protocol.DatanodeID convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto dn)
public static DatanodeInfo.AdminStates convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto.AdminState adminState)
public static org.apache.hadoop.hdfs.protocol.LocatedBlocks convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto lb)
public static org.apache.hadoop.hdfs.protocol.BlockStoragePolicy[] convertStoragePolicies(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto> policyProtos)
public static org.apache.hadoop.hdfs.inotify.EventBatchList convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetEditsFromTxidResponseProto resp)
throws IOException
IOExceptionpublic static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] convertLocatedBlock(org.apache.hadoop.hdfs.protocol.LocatedBlock[] lb)
public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> convertLocatedBlock2(List<org.apache.hadoop.hdfs.protocol.LocatedBlock> lb)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto convert(org.apache.hadoop.hdfs.protocol.LocatedBlock b)
public static org.apache.hadoop.hdfs.protocol.BlockStoragePolicy convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto proto)
public static org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto.FsActionProto convert(org.apache.hadoop.fs.permission.FsAction v)
public static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto convertXAttrProto(org.apache.hadoop.fs.XAttr a)
public static List<org.apache.hadoop.fs.XAttr> convert(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.ListXAttrsResponseProto a)
public static List<org.apache.hadoop.fs.XAttr> convert(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsResponseProto a)
public static List<org.apache.hadoop.fs.XAttr> convertXAttrs(List<org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto> xAttrSpec)
public static List<org.apache.hadoop.hdfs.protocol.LocatedBlock> convertLocatedBlock(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto> lb)
public static List<org.apache.hadoop.fs.permission.AclEntry> convertAclEntry(List<org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto> aclSpec)
public static org.apache.hadoop.fs.permission.FsAction convert(org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto.FsActionProto v)
public static org.apache.hadoop.fs.permission.FsPermission convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsPermissionProto p)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FileEncryptionInfoProto convert(org.apache.hadoop.fs.FileEncryptionInfo info)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto convert(org.apache.hadoop.crypto.CryptoProtocolVersion version)
public static org.apache.hadoop.fs.FileEncryptionInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FileEncryptionInfoProto proto)
public static org.apache.hadoop.crypto.CryptoProtocolVersion convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto proto)
public static List<org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto> convertXAttrProto(List<org.apache.hadoop.fs.XAttr> xAttrSpec)
public static int convert(EnumSet<org.apache.hadoop.fs.XAttrSetFlag> flag)
public static EncryptionZone convert(org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.EncryptionZoneProto proto)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesBatchResponseProto convert(org.apache.hadoop.hdfs.protocol.OpenFileEntry openFileEntry)
public static org.apache.hadoop.hdfs.protocol.OpenFileEntry convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.OpenFilesBatchResponseProto proto)
public static org.apache.hadoop.fs.permission.AclStatus convert(org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusResponseProto e)
public static List<org.apache.hadoop.hdfs.protocol.proto.AclProtos.AclEntryProto> convertAclEntryProto(List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)
public static CachePoolEntry convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolEntryProto proto)
public static CachePoolInfo convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolInfoProto proto)
public static CachePoolStats convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolStatsProto proto)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolInfoProto convert(CachePoolInfo info)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto convert(CacheDirectiveInfo info)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoExpirationProto convert(CacheDirectiveInfo.Expiration expiration)
public static CacheDirectiveEntry convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveEntryProto proto)
public static CacheDirectiveStats convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveStatsProto proto)
public static CacheDirectiveInfo convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto proto)
public static CacheDirectiveInfo.Expiration convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoExpirationProto proto)
public static SnapshotDiffReport convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportProto reportProto)
public static SnapshotDiffReport.DiffReportEntry convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportEntryProto entry)
public static SnapshottableDirectoryStatus[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryListingProto sdlp)
public static SnapshottableDirectoryStatus convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryStatusProto sdirStatusProto)
public static org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DataEncryptionKeyProto bet)
public static org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier> convertDelegationToken(org.apache.hadoop.security.proto.SecurityProtos.TokenProto blockToken)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[] convert(org.apache.hadoop.hdfs.protocol.DatanodeID[] did)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsPermissionProto convert(org.apache.hadoop.fs.permission.FsPermission p)
public static org.apache.hadoop.hdfs.protocol.HdfsFileStatus convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto fs)
public static CorruptFileBlocks convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CorruptFileBlocksProto c)
public static org.apache.hadoop.fs.ContentSummary convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ContentSummaryProto cs)
public static org.apache.hadoop.fs.QuotaUsage convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.QuotaUsageProto qu)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.QuotaUsageProto convert(org.apache.hadoop.fs.QuotaUsage qu)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeActionProto convert(HdfsConstants.RollingUpgradeAction a)
public static org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeInfoProto proto)
public static DatanodeStorageReport[] convertDatanodeStorageReports(List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto> protos)
public static DatanodeStorageReport convertDatanodeStorageReport(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto proto)
public static StorageReport[] convertStorageReports(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto> list)
public static StorageReport convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto p)
public static DatanodeStorage convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeStorageProto s)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.SafeModeActionProto convert(HdfsConstants.SafeModeAction a)
public static org.apache.hadoop.hdfs.protocol.DatanodeInfo[] convert(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto> list)
public static long[] convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsStatsResponseProto res)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeReportTypeProto convert(HdfsConstants.DatanodeReportType t)
public static org.apache.hadoop.hdfs.protocol.DirectoryListing convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DirectoryListingProto dl)
public static org.apache.hadoop.hdfs.protocol.HdfsFileStatus[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto[] fs)
public static int convertCreateFlag(org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> flag)
public static org.apache.hadoop.fs.FsServerDefaults convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsServerDefaultsProto fs)
public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto> convert(org.apache.hadoop.crypto.CryptoProtocolVersion[] versions)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockStoragePolicyProto convert(org.apache.hadoop.hdfs.protocol.BlockStoragePolicy policy)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageTypesProto convert(org.apache.hadoop.fs.StorageType[] types)
public static org.apache.hadoop.hdfs.protocol.DatanodeID[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[] did)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto convert(org.apache.hadoop.hdfs.protocol.Block b)
public static org.apache.hadoop.hdfs.protocol.Block convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto b)
public static org.apache.hadoop.hdfs.protocol.DatanodeInfo[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto[] di)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto convertDatanodeStorageReport(DatanodeStorageReport report)
public static List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeStorageReportProto> convertDatanodeStorageReports(DatanodeStorageReport[] reports)
public static org.apache.hadoop.hdfs.protocol.LocatedBlock[] convertLocatedBlock(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto[] lb)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto convert(org.apache.hadoop.hdfs.protocol.LocatedBlocks lb)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DataEncryptionKeyProto convert(org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey bet)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.FsServerDefaultsProto convert(org.apache.hadoop.fs.FsServerDefaults fs)
public static org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> convertCreateFlag(int flag)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto convert(org.apache.hadoop.hdfs.protocol.HdfsFileStatus fs)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryStatusProto convert(SnapshottableDirectoryStatus status)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.HdfsFileStatusProto[] convert(org.apache.hadoop.hdfs.protocol.HdfsFileStatus[] fs)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DirectoryListingProto convert(org.apache.hadoop.hdfs.protocol.DirectoryListing d)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFsStatsResponseProto convert(long[] fsStats)
public static HdfsConstants.DatanodeReportType convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.DatanodeReportTypeProto t)
public static HdfsConstants.SafeModeAction convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.SafeModeActionProto a)
public static HdfsConstants.RollingUpgradeAction convert(org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeActionProto a)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto convertRollingUpgradeStatus(org.apache.hadoop.hdfs.protocol.RollingUpgradeStatus status)
public static org.apache.hadoop.hdfs.protocol.RollingUpgradeStatus convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RollingUpgradeStatusProto proto)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RollingUpgradeInfoProto convert(org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo info)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CorruptFileBlocksProto convert(CorruptFileBlocks c)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.ContentSummaryProto convert(org.apache.hadoop.fs.ContentSummary cs)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeStorageProto convert(DatanodeStorage s)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto convert(StorageReport r)
public static List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.StorageReportProto> convertStorageReports(StorageReport[] storages)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshottableDirectoryListingProto convert(SnapshottableDirectoryStatus[] status)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportEntryProto convert(SnapshotDiffReport.DiffReportEntry entry)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.SnapshotDiffReportProto convert(SnapshotDiffReport report)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveStatsProto convert(CacheDirectiveStats stats)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveEntryProto convert(CacheDirectiveEntry entry)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolStatsProto convert(CachePoolStats stats)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CachePoolEntryProto convert(CachePoolEntry entry)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeLocalInfoProto convert(org.apache.hadoop.hdfs.protocol.DatanodeLocalInfo info)
public static org.apache.hadoop.hdfs.protocol.proto.AclProtos.GetAclStatusResponseProto convert(org.apache.hadoop.fs.permission.AclStatus e)
public static EnumSet<org.apache.hadoop.fs.XAttrSetFlag> convert(int flag)
public static org.apache.hadoop.fs.XAttr convertXAttr(org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.XAttrProto a)
public static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.GetXAttrsResponseProto convertXAttrsResponse(List<org.apache.hadoop.fs.XAttr> xAttrs)
public static org.apache.hadoop.hdfs.protocol.proto.XAttrProtos.ListXAttrsResponseProto convertListXAttrsResponse(List<org.apache.hadoop.fs.XAttr> names)
public static org.apache.hadoop.hdfs.protocol.proto.EncryptionZonesProtos.EncryptionZoneProto convert(EncryptionZone zone)
public static ShortCircuitShm.SlotId convert(org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ShortCircuitShmSlotProto slotId)
public static org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetEditsFromTxidResponseProto convertEditsResponse(org.apache.hadoop.hdfs.inotify.EventBatchList el)
public static org.apache.hadoop.crypto.CryptoProtocolVersion[] convertCryptoProtocolVersions(List<org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.CryptoProtocolVersionProto> protos)
public static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.PerFileEncryptionInfoProto convertPerFileEncInfo(org.apache.hadoop.fs.FileEncryptionInfo info)
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)
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)
public static org.apache.hadoop.hdfs.protocol.DatanodeInfo[] convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfosProto datanodeInfosProto)
public static EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> convertAddBlockFlags(List<org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlockFlagProto> addBlockFlags)
Copyright © 2018 Apache Software Foundation. All Rights Reserved.