org.apache.hadoop.hdfs.protocolPB

Class PBHelper

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.PBHelper

public class PBHelper
extends Object

Utilities for converting protobuf classes to and from 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. For those helper methods that convert HDFS client-side data structures from and to protobuf, see PBHelperClient.

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BalancerBandwidthCommandProto	convert(BalancerBandwidthCommand bbCmd)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.BlockCommand cmd)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockIdCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.BlockIdCommand cmd)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockKeyProto	convert(org.apache.hadoop.hdfs.security.token.block.BlockKey key)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RecoveringBlockProto	convert(org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand.RecoveringBlock b)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockRecoveryCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand cmd)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportContextProto	convert(org.apache.hadoop.hdfs.server.protocol.BlockReportContext context)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockWithLocationsProto	convert(org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations.BlockWithLocations blk)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlocksWithLocationsProto	convert(org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations blks)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.CheckpointCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.CheckpointCommand cmd)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.CheckpointSignatureProto	convert(org.apache.hadoop.hdfs.server.namenode.CheckpointSignature s)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.DatanodeCommand datanodeCommand)
static BalancerBandwidthCommand	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BalancerBandwidthCommandProto balancerCmd)
static org.apache.hadoop.hdfs.server.protocol.BlockCommand	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockCommandProto blkCmd)
static org.apache.hadoop.hdfs.server.protocol.BlockIdCommand	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockIdCommandProto blkIdCmd)
static org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockRecoveryCommandProto recoveryCmd)
static org.apache.hadoop.hdfs.server.protocol.BlockReportContext	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportContextProto proto)
static org.apache.hadoop.hdfs.server.protocol.DatanodeCommand	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeCommandProto proto)
static org.apache.hadoop.hdfs.server.protocol.DatanodeRegistration	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeRegistrationProto proto)
static org.apache.hadoop.hdfs.server.protocol.FinalizeCommand	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.FinalizeCommandProto finalizeCmd)
static org.apache.hadoop.hdfs.server.protocol.KeyUpdateCommand	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.KeyUpdateCommandProto keyUpdateCmd)
static ReceivedDeletedBlockInfo	convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReceivedDeletedBlockInfoProto proto)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeRegistrationProto	convert(org.apache.hadoop.hdfs.server.protocol.DatanodeRegistration registration)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ExportedBlockKeysProto	convert(org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys keys)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.FinalizeCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.FinalizeCommand cmd)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto.State	convert(org.apache.hadoop.ha.HAServiceProtocol.HAServiceState s)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto.NamenodeRoleProto	convert(HdfsServerConstants.NamenodeRole role)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ReplicaStateProto	convert(HdfsServerConstants.ReplicaState state)
static org.apache.hadoop.hdfs.security.token.block.BlockKey	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockKeyProto k)
static org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlocksWithLocationsProto blocks)
static org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations.BlockWithLocations	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockWithLocationsProto b)
static org.apache.hadoop.hdfs.server.namenode.CheckpointSignature	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.CheckpointSignatureProto s)
static org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ExportedBlockKeysProto keys)
static org.apache.hadoop.hdfs.server.protocol.NamenodeCommand	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeCommandProto cmd)
static HdfsServerConstants.NamenodeRole	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto.NamenodeRoleProto role)
static org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto reg)
static org.apache.hadoop.hdfs.server.protocol.NamespaceInfo	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamespaceInfoProto info)
static org.apache.hadoop.ha.HAServiceProtocol.HAServiceState	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto.State s)
static org.apache.hadoop.hdfs.server.protocol.NNHAStatusHeartbeat	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto s)
static org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand.RecoveringBlock	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RecoveringBlockProto b)
static RemoteEditLogManifest	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogManifestProto manifest)
static RemoteEditLog	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogProto l)
static HdfsServerConstants.ReplicaState	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ReplicaStateProto state)
static org.apache.hadoop.hdfs.server.common.StorageInfo	convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.StorageInfoProto info, HdfsServerConstants.NodeType type)
static org.apache.hadoop.hdfs.protocol.proto.JournalProtocolProtos.JournalInfoProto	convert(org.apache.hadoop.hdfs.server.protocol.JournalInfo j) Method used for converting JournalProtocolProtos.JournalInfoProto sent from Namenode to Journal receivers to NamenodeRegistration.
static org.apache.hadoop.hdfs.server.protocol.JournalInfo	convert(org.apache.hadoop.hdfs.protocol.proto.JournalProtocolProtos.JournalInfoProto info)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.KeyUpdateCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.KeyUpdateCommand cmd)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeCommandProto	convert(org.apache.hadoop.hdfs.server.protocol.NamenodeCommand cmd)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto	convert(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration reg)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamespaceInfoProto	convert(org.apache.hadoop.hdfs.server.protocol.NamespaceInfo info)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto	convert(org.apache.hadoop.hdfs.server.protocol.NNHAStatusHeartbeat hb)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReceivedDeletedBlockInfoProto	convert(ReceivedDeletedBlockInfo receivedDeletedBlockInfo)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogProto	convert(RemoteEditLog log)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogManifestProto	convert(RemoteEditLogManifest manifest)
static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.StorageInfoProto	convert(org.apache.hadoop.hdfs.server.common.StorageInfo info)
static org.apache.hadoop.hdfs.security.token.block.BlockKey[]	convertBlockKeys(List<org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockKeyProto> list)
static VolumeFailureSummary	convertVolumeFailureSummary(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.VolumeFailureSummaryProto proto)
static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.VolumeFailureSummaryProto	convertVolumeFailureSummary(VolumeFailureSummary volumeFailureSummary)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

convert

public static HdfsServerConstants.NamenodeRole convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto.NamenodeRoleProto role)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto.NamenodeRoleProto convert(HdfsServerConstants.NamenodeRole role)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.StorageInfoProto convert(org.apache.hadoop.hdfs.server.common.StorageInfo info)

convert

public static org.apache.hadoop.hdfs.server.common.StorageInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.StorageInfoProto info,
                                                       HdfsServerConstants.NodeType type)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto convert(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration reg)

convert

public static org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeRegistrationProto reg)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockWithLocationsProto convert(org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations.BlockWithLocations blk)

convert

public static org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations.BlockWithLocations convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockWithLocationsProto b)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlocksWithLocationsProto convert(org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations blks)

convert

public static org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlocksWithLocationsProto blocks)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockKeyProto convert(org.apache.hadoop.hdfs.security.token.block.BlockKey key)

convert

public static org.apache.hadoop.hdfs.security.token.block.BlockKey convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockKeyProto k)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ExportedBlockKeysProto convert(org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys keys)

convert

public static org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ExportedBlockKeysProto keys)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.CheckpointSignatureProto convert(org.apache.hadoop.hdfs.server.namenode.CheckpointSignature s)

convert

public static org.apache.hadoop.hdfs.server.namenode.CheckpointSignature convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.CheckpointSignatureProto s)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogProto convert(RemoteEditLog log)

convert

public static RemoteEditLog convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogProto l)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogManifestProto convert(RemoteEditLogManifest manifest)

convert

public static RemoteEditLogManifest convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RemoteEditLogManifestProto manifest)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.CheckpointCommandProto convert(org.apache.hadoop.hdfs.server.protocol.CheckpointCommand cmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeCommandProto convert(org.apache.hadoop.hdfs.server.protocol.NamenodeCommand cmd)

convertBlockKeys

public static org.apache.hadoop.hdfs.security.token.block.BlockKey[] convertBlockKeys(List<org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.BlockKeyProto> list)

convert

public static org.apache.hadoop.hdfs.server.protocol.NamespaceInfo convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamespaceInfoProto info)

convert

public static org.apache.hadoop.hdfs.server.protocol.NamenodeCommand convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamenodeCommandProto cmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RecoveringBlockProto convert(org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand.RecoveringBlock b)

convert

public static org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand.RecoveringBlock convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.RecoveringBlockProto b)

convert

public static HdfsServerConstants.ReplicaState convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ReplicaStateProto state)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.ReplicaStateProto convert(HdfsServerConstants.ReplicaState state)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeRegistrationProto convert(org.apache.hadoop.hdfs.server.protocol.DatanodeRegistration registration)

convert

public static org.apache.hadoop.hdfs.server.protocol.DatanodeRegistration convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeRegistrationProto proto)

convert

public static org.apache.hadoop.hdfs.server.protocol.DatanodeCommand convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeCommandProto proto)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BalancerBandwidthCommandProto convert(BalancerBandwidthCommand bbCmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.KeyUpdateCommandProto convert(org.apache.hadoop.hdfs.server.protocol.KeyUpdateCommand cmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockRecoveryCommandProto convert(org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand cmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.FinalizeCommandProto convert(org.apache.hadoop.hdfs.server.protocol.FinalizeCommand cmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockCommandProto convert(org.apache.hadoop.hdfs.server.protocol.BlockCommand cmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockIdCommandProto convert(org.apache.hadoop.hdfs.server.protocol.BlockIdCommand cmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeCommandProto convert(org.apache.hadoop.hdfs.server.protocol.DatanodeCommand datanodeCommand)

convert

public static org.apache.hadoop.hdfs.server.protocol.KeyUpdateCommand convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.KeyUpdateCommandProto keyUpdateCmd)

convert

public static org.apache.hadoop.hdfs.server.protocol.FinalizeCommand convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.FinalizeCommandProto finalizeCmd)

convert

public static org.apache.hadoop.hdfs.server.protocol.BlockRecoveryCommand convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockRecoveryCommandProto recoveryCmd)

convert

public static org.apache.hadoop.hdfs.server.protocol.BlockCommand convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockCommandProto blkCmd)

convert

public static org.apache.hadoop.hdfs.server.protocol.BlockIdCommand convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockIdCommandProto blkIdCmd)

convert

public static BalancerBandwidthCommand convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BalancerBandwidthCommandProto balancerCmd)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReceivedDeletedBlockInfoProto convert(ReceivedDeletedBlockInfo receivedDeletedBlockInfo)

convert

public static ReceivedDeletedBlockInfo convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReceivedDeletedBlockInfoProto proto)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NamespaceInfoProto convert(org.apache.hadoop.hdfs.server.protocol.NamespaceInfo info)

convert

public static org.apache.hadoop.ha.HAServiceProtocol.HAServiceState convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto.State s)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto.State convert(org.apache.hadoop.ha.HAServiceProtocol.HAServiceState s)

convert

public static org.apache.hadoop.hdfs.server.protocol.NNHAStatusHeartbeat convert(org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto s)

convert

public static org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.NNHAStatusHeartbeatProto convert(org.apache.hadoop.hdfs.server.protocol.NNHAStatusHeartbeat hb)

convertVolumeFailureSummary

public static VolumeFailureSummary convertVolumeFailureSummary(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.VolumeFailureSummaryProto proto)

convertVolumeFailureSummary

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.VolumeFailureSummaryProto convertVolumeFailureSummary(VolumeFailureSummary volumeFailureSummary)

convert

public static org.apache.hadoop.hdfs.server.protocol.JournalInfo convert(org.apache.hadoop.hdfs.protocol.proto.JournalProtocolProtos.JournalInfoProto info)

convert

public static org.apache.hadoop.hdfs.protocol.proto.JournalProtocolProtos.JournalInfoProto convert(org.apache.hadoop.hdfs.server.protocol.JournalInfo j)

Method used for converting JournalProtocolProtos.JournalInfoProto sent from Namenode to Journal receivers to NamenodeRegistration.

convert

public static org.apache.hadoop.hdfs.server.protocol.BlockReportContext convert(org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportContextProto proto)

convert

public static org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportContextProto convert(org.apache.hadoop.hdfs.server.protocol.BlockReportContext context)