public class PBHelper extends Object
public static com.google.protobuf.ByteString getByteString(byte[] bytes)
public static HdfsServerConstants.NamenodeRole convert(HdfsProtos.NamenodeRegistrationProto.NamenodeRoleProto role)
public static HdfsProtos.NamenodeRegistrationProto.NamenodeRoleProto convert(HdfsServerConstants.NamenodeRole role)
public static HdfsProtos.StorageInfoProto convert(StorageInfo info)
public static StorageInfo convert(HdfsProtos.StorageInfoProto info)
public static HdfsProtos.NamenodeRegistrationProto convert(NamenodeRegistration reg)
public static NamenodeRegistration convert(HdfsProtos.NamenodeRegistrationProto reg)
public static DatanodeID convert(HdfsProtos.DatanodeIDProto dn)
public static HdfsProtos.DatanodeIDProto convert(DatanodeID dn)
public static HdfsProtos.DatanodeIDProto[] convert(DatanodeID[] did)
public static DatanodeID[] convert(HdfsProtos.DatanodeIDProto[] did)
public static HdfsProtos.BlockProto convert(Block b)
public static Block convert(HdfsProtos.BlockProto b)
public static HdfsProtos.BlockWithLocationsProto convert(BlocksWithLocations.BlockWithLocations blk)
public static BlocksWithLocations.BlockWithLocations convert(HdfsProtos.BlockWithLocationsProto b)
public static HdfsProtos.BlocksWithLocationsProto convert(BlocksWithLocations blks)
public static BlocksWithLocations convert(HdfsProtos.BlocksWithLocationsProto blocks)
public static HdfsProtos.BlockKeyProto convert(BlockKey key)
public static BlockKey convert(HdfsProtos.BlockKeyProto k)
public static HdfsProtos.ExportedBlockKeysProto convert(ExportedBlockKeys keys)
public static ExportedBlockKeys convert(HdfsProtos.ExportedBlockKeysProto keys)
public static HdfsProtos.CheckpointSignatureProto convert(CheckpointSignature s)
public static CheckpointSignature convert(HdfsProtos.CheckpointSignatureProto s)
public static HdfsProtos.RemoteEditLogProto convert(RemoteEditLog log)
public static RemoteEditLog convert(HdfsProtos.RemoteEditLogProto l)
public static HdfsProtos.RemoteEditLogManifestProto convert(RemoteEditLogManifest manifest)
public static RemoteEditLogManifest convert(HdfsProtos.RemoteEditLogManifestProto manifest)
public static HdfsProtos.CheckpointCommandProto convert(CheckpointCommand cmd)
public static HdfsProtos.NamenodeCommandProto convert(NamenodeCommand cmd)
public static BlockKey[] convertBlockKeys(List<HdfsProtos.BlockKeyProto> list)
public static NamespaceInfo convert(HdfsProtos.NamespaceInfoProto info)
public static NamenodeCommand convert(HdfsProtos.NamenodeCommandProto cmd)
public static ExtendedBlock convert(HdfsProtos.ExtendedBlockProto eb)
public static HdfsProtos.ExtendedBlockProto convert(ExtendedBlock b)
public static HdfsProtos.RecoveringBlockProto convert(BlockRecoveryCommand.RecoveringBlock b)
public static BlockRecoveryCommand.RecoveringBlock convert(HdfsProtos.RecoveringBlockProto b)
public static HdfsProtos.DatanodeInfoProto.AdminState convert(DatanodeInfo.AdminStates inAs)
public static DatanodeInfo convert(HdfsProtos.DatanodeInfoProto di)
public static HdfsProtos.DatanodeInfoProto convertDatanodeInfo(DatanodeInfo di)
public static DatanodeInfo[] convert(HdfsProtos.DatanodeInfoProto[] di)
public static List<? extends HdfsProtos.DatanodeInfoProto> convert(DatanodeInfo[] dnInfos)
public static List<? extends HdfsProtos.DatanodeInfoProto> convert(DatanodeInfo[] dnInfos, int startIdx)
dnInfos
to a target of list of same size starting at
startIdx
.public static DatanodeInfo[] convert(List<HdfsProtos.DatanodeInfoProto> list)
public static HdfsProtos.DatanodeInfoProto convert(DatanodeInfo info)
public static DatanodeInfo.AdminStates convert(HdfsProtos.DatanodeInfoProto.AdminState adminState)
public static HdfsProtos.LocatedBlockProto convert(LocatedBlock b)
public static LocatedBlock convert(HdfsProtos.LocatedBlockProto proto)
public static SecurityProtos.TokenProto convert(Token<?> tok)
public static Token<BlockTokenIdentifier> convert(SecurityProtos.TokenProto blockToken)
public static Token<DelegationTokenIdentifier> convertDelegationToken(SecurityProtos.TokenProto blockToken)
public static HdfsServerConstants.ReplicaState convert(HdfsProtos.ReplicaStateProto state)
public static HdfsProtos.ReplicaStateProto convert(HdfsServerConstants.ReplicaState state)
public static DatanodeProtocolProtos.DatanodeRegistrationProto convert(DatanodeRegistration registration)
public static DatanodeRegistration convert(DatanodeProtocolProtos.DatanodeRegistrationProto proto)
public static DatanodeCommand convert(DatanodeProtocolProtos.DatanodeCommandProto proto)
public static DatanodeProtocolProtos.BalancerBandwidthCommandProto convert(BalancerBandwidthCommand bbCmd)
public static DatanodeProtocolProtos.KeyUpdateCommandProto convert(KeyUpdateCommand cmd)
public static DatanodeProtocolProtos.BlockRecoveryCommandProto convert(BlockRecoveryCommand cmd)
public static DatanodeProtocolProtos.FinalizeCommandProto convert(FinalizeCommand cmd)
public static DatanodeProtocolProtos.BlockCommandProto convert(BlockCommand cmd)
public static DatanodeProtocolProtos.DatanodeCommandProto convert(DatanodeCommand datanodeCommand)
public static KeyUpdateCommand convert(DatanodeProtocolProtos.KeyUpdateCommandProto keyUpdateCmd)
public static FinalizeCommand convert(DatanodeProtocolProtos.FinalizeCommandProto finalizeCmd)
public static BlockRecoveryCommand convert(DatanodeProtocolProtos.BlockRecoveryCommandProto recoveryCmd)
public static BlockCommand convert(DatanodeProtocolProtos.BlockCommandProto blkCmd)
public static DatanodeInfo[] convert(HdfsProtos.DatanodeInfosProto datanodeInfosProto)
public static BalancerBandwidthCommand convert(DatanodeProtocolProtos.BalancerBandwidthCommandProto balancerCmd)
public static DatanodeProtocolProtos.ReceivedDeletedBlockInfoProto convert(ReceivedDeletedBlockInfo receivedDeletedBlockInfo)
public static ReceivedDeletedBlockInfo convert(DatanodeProtocolProtos.ReceivedDeletedBlockInfoProto proto)
public static HdfsProtos.NamespaceInfoProto convert(NamespaceInfo info)
public static HdfsProtos.LocatedBlockProto[] convertLocatedBlock(LocatedBlock[] lb)
public static LocatedBlock[] convertLocatedBlock(HdfsProtos.LocatedBlockProto[] lb)
public static List<LocatedBlock> convertLocatedBlock(List<HdfsProtos.LocatedBlockProto> lb)
public static List<HdfsProtos.LocatedBlockProto> convertLocatedBlock2(List<LocatedBlock> lb)
public static LocatedBlocks convert(HdfsProtos.LocatedBlocksProto lb)
public static HdfsProtos.LocatedBlocksProto convert(LocatedBlocks lb)
public static DataEncryptionKey convert(HdfsProtos.DataEncryptionKeyProto bet)
public static HdfsProtos.DataEncryptionKeyProto convert(DataEncryptionKey bet)
public static FsServerDefaults convert(HdfsProtos.FsServerDefaultsProto fs)
public static HdfsProtos.FsServerDefaultsProto convert(FsServerDefaults fs)
public static HdfsProtos.FsPermissionProto convert(FsPermission p)
public static FsPermission convert(HdfsProtos.FsPermissionProto p)
public static int convertCreateFlag(EnumSetWritable<CreateFlag> flag)
public static EnumSetWritable<CreateFlag> convert(int flag)
public static HdfsFileStatus convert(HdfsProtos.HdfsFileStatusProto fs)
public static SnapshottableDirectoryStatus convert(HdfsProtos.SnapshottableDirectoryStatusProto sdirStatusProto)
public static HdfsProtos.HdfsFileStatusProto convert(HdfsFileStatus fs)
public static HdfsProtos.SnapshottableDirectoryStatusProto convert(SnapshottableDirectoryStatus status)
public static HdfsProtos.HdfsFileStatusProto[] convert(HdfsFileStatus[] fs)
public static HdfsFileStatus[] convert(HdfsProtos.HdfsFileStatusProto[] fs)
public static DirectoryListing convert(HdfsProtos.DirectoryListingProto dl)
public static HdfsProtos.DirectoryListingProto convert(DirectoryListing d)
public static long[] convert(ClientNamenodeProtocolProtos.GetFsStatsResponseProto res)
public static ClientNamenodeProtocolProtos.GetFsStatsResponseProto convert(long[] fsStats)
public static ClientNamenodeProtocolProtos.DatanodeReportTypeProto convert(HdfsConstants.DatanodeReportType t)
public static HdfsConstants.DatanodeReportType convert(ClientNamenodeProtocolProtos.DatanodeReportTypeProto t)
public static ClientNamenodeProtocolProtos.SafeModeActionProto convert(HdfsConstants.SafeModeAction a)
public static HdfsConstants.SafeModeAction convert(ClientNamenodeProtocolProtos.SafeModeActionProto a)
public static CorruptFileBlocks convert(HdfsProtos.CorruptFileBlocksProto c)
public static HdfsProtos.CorruptFileBlocksProto convert(CorruptFileBlocks c)
public static ContentSummary convert(HdfsProtos.ContentSummaryProto cs)
public static HdfsProtos.ContentSummaryProto convert(ContentSummary cs)
public static NNHAStatusHeartbeat convert(DatanodeProtocolProtos.NNHAStatusHeartbeatProto s)
public static DatanodeProtocolProtos.NNHAStatusHeartbeatProto convert(NNHAStatusHeartbeat hb)
public static DatanodeProtocolProtos.DatanodeStorageProto convert(DatanodeStorage s)
public static DatanodeStorage convert(DatanodeProtocolProtos.DatanodeStorageProto s)
public static DatanodeProtocolProtos.StorageReportProto convert(StorageReport r)
public static JournalInfo convert(JournalProtocolProtos.JournalInfoProto info)
public static JournalProtocolProtos.JournalInfoProto convert(JournalInfo j)
JournalProtocolProtos.JournalInfoProto
sent from Namenode
to Journal receivers to NamenodeRegistration
.public static SnapshottableDirectoryStatus[] convert(HdfsProtos.SnapshottableDirectoryListingProto sdlp)
public static HdfsProtos.SnapshottableDirectoryListingProto convert(SnapshottableDirectoryStatus[] status)
public static SnapshotDiffReport.DiffReportEntry convert(HdfsProtos.SnapshotDiffReportEntryProto entry)
public static HdfsProtos.SnapshotDiffReportEntryProto convert(SnapshotDiffReport.DiffReportEntry entry)
public static SnapshotDiffReport convert(HdfsProtos.SnapshotDiffReportProto reportProto)
public static HdfsProtos.SnapshotDiffReportProto convert(SnapshotDiffReport report)
public static DataChecksum.Type convert(HdfsProtos.ChecksumTypeProto type)
public static HdfsProtos.ChecksumTypeProto convert(DataChecksum.Type type)
public static InputStream vintPrefixed(InputStream input) throws IOException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.