org.apache.hadoop.hdfs.protocol.proto

Class DatanodeProtocolProtos.HeartbeatRequestProto.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder<BuilderType>

com.google.protobuf.AbstractMessage.Builder<BuilderType>

com.google.protobuf.GeneratedMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.HeartbeatRequestProto.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

Enclosing class:

DatanodeProtocolProtos.HeartbeatRequestProto

public static final class DatanodeProtocolProtos.HeartbeatRequestProto.Builder
extends com.google.protobuf.GeneratedMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>
implements DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

Protobuf type hadoop.hdfs.HeartbeatRequestProto

 registration - datanode registration information
 capacity - total storage capacity available at the datanode
 dfsUsed - storage used by HDFS
 remaining - remaining storage available for HDFS
 blockPoolUsed - storage used by the block pool
 xmitsInProgress - number of transfers from this datanode to others
 xceiverCount - number of active transceiver threads
 failedVolumes - number of failed volumes
 

Method Summary

Methods

Modifier and Type	Method and Description
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	addAllReports(Iterable<? extends DatanodeProtocolProtos.StorageReportProto> values) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	addReports(DatanodeProtocolProtos.StorageReportProto.Builder builderForValue) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	addReports(DatanodeProtocolProtos.StorageReportProto value) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	addReports(int index, DatanodeProtocolProtos.StorageReportProto.Builder builderForValue) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	addReports(int index, DatanodeProtocolProtos.StorageReportProto value) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.StorageReportProto.Builder	addReportsBuilder() repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.StorageReportProto.Builder	addReportsBuilder(int index) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto	build()
DatanodeProtocolProtos.HeartbeatRequestProto	buildPartial()
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	clear()
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	clearFailedVolumes() optional uint32 failedVolumes = 5 [default = 0];
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	clearRegistration() required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	clearReports() repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	clearXceiverCount() optional uint32 xceiverCount = 4 [default = 0];
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	clearXmitsInProgress() optional uint32 xmitsInProgress = 3 [default = 0];
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	clone()
DatanodeProtocolProtos.HeartbeatRequestProto	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
int	getFailedVolumes() optional uint32 failedVolumes = 5 [default = 0];
DatanodeProtocolProtos.DatanodeRegistrationProto	getRegistration() required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
DatanodeProtocolProtos.DatanodeRegistrationProto.Builder	getRegistrationBuilder() required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
DatanodeProtocolProtos.DatanodeRegistrationProtoOrBuilder	getRegistrationOrBuilder() required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
DatanodeProtocolProtos.StorageReportProto	getReports(int index) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.StorageReportProto.Builder	getReportsBuilder(int index) repeated .hadoop.hdfs.StorageReportProto reports = 2;
List<DatanodeProtocolProtos.StorageReportProto.Builder>	getReportsBuilderList() repeated .hadoop.hdfs.StorageReportProto reports = 2;
int	getReportsCount() repeated .hadoop.hdfs.StorageReportProto reports = 2;
List<DatanodeProtocolProtos.StorageReportProto>	getReportsList() repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.StorageReportProtoOrBuilder	getReportsOrBuilder(int index) repeated .hadoop.hdfs.StorageReportProto reports = 2;
List<? extends DatanodeProtocolProtos.StorageReportProtoOrBuilder>	getReportsOrBuilderList() repeated .hadoop.hdfs.StorageReportProto reports = 2;
int	getXceiverCount() optional uint32 xceiverCount = 4 [default = 0];
int	getXmitsInProgress() optional uint32 xmitsInProgress = 3 [default = 0];
boolean	hasFailedVolumes() optional uint32 failedVolumes = 5 [default = 0];
boolean	hasRegistration() required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
boolean	hasXceiverCount() optional uint32 xceiverCount = 4 [default = 0];
boolean	hasXmitsInProgress() optional uint32 xmitsInProgress = 3 [default = 0];
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	mergeFrom(DatanodeProtocolProtos.HeartbeatRequestProto other)
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	mergeFrom(com.google.protobuf.Message other)
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	mergeRegistration(DatanodeProtocolProtos.DatanodeRegistrationProto value) required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	removeReports(int index) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	setFailedVolumes(int value) optional uint32 failedVolumes = 5 [default = 0];
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	setRegistration(DatanodeProtocolProtos.DatanodeRegistrationProto.Builder builderForValue) required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	setRegistration(DatanodeProtocolProtos.DatanodeRegistrationProto value) required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	setReports(int index, DatanodeProtocolProtos.StorageReportProto.Builder builderForValue) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	setReports(int index, DatanodeProtocolProtos.StorageReportProto value) repeated .hadoop.hdfs.StorageReportProto reports = 2;
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	setXceiverCount(int value) optional uint32 xceiverCount = 4 [default = 0];
DatanodeProtocolProtos.HeartbeatRequestProto.Builder	setXmitsInProgress(int value) optional uint32 xmitsInProgress = 3 [default = 0];

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, getAllFields, getField, getFieldBuilder, getParentForChildren, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, isClean, markClean, mergeUnknownFields, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFields

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

addAll, newUninitializedMessageException

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField

Method Detail

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

clear

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

clone

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder clone()

Specified by:

clone in interface com.google.protobuf.Message.Builder

Specified by:

clone in interface com.google.protobuf.MessageLite.Builder

Overrides:

clone in class com.google.protobuf.GeneratedMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

getDefaultInstanceForType

public DatanodeProtocolProtos.HeartbeatRequestProto getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public DatanodeProtocolProtos.HeartbeatRequestProto build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public DatanodeProtocolProtos.HeartbeatRequestProto buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

mergeFrom

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder mergeFrom(DatanodeProtocolProtos.HeartbeatRequestProto other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

mergeFrom

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder mergeFrom(com.google.protobuf.CodedInputStream input,
                                                             com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                               throws IOException

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<DatanodeProtocolProtos.HeartbeatRequestProto.Builder>

Throws:

IOException

hasRegistration

public boolean hasRegistration()

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

Specified by:

hasRegistration in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getRegistration

public DatanodeProtocolProtos.DatanodeRegistrationProto getRegistration()

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

Specified by:

getRegistration in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

setRegistration

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder setRegistration(DatanodeProtocolProtos.DatanodeRegistrationProto value)

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

setRegistration

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder setRegistration(DatanodeProtocolProtos.DatanodeRegistrationProto.Builder builderForValue)

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

mergeRegistration

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder mergeRegistration(DatanodeProtocolProtos.DatanodeRegistrationProto value)

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

clearRegistration

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder clearRegistration()

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

getRegistrationBuilder

public DatanodeProtocolProtos.DatanodeRegistrationProto.Builder getRegistrationBuilder()

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

getRegistrationOrBuilder

public DatanodeProtocolProtos.DatanodeRegistrationProtoOrBuilder getRegistrationOrBuilder()

required .hadoop.hdfs.DatanodeRegistrationProto registration = 1;

 Datanode info
 

Specified by:

getRegistrationOrBuilder in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getReportsList

public List<DatanodeProtocolProtos.StorageReportProto> getReportsList()

repeated .hadoop.hdfs.StorageReportProto reports = 2;

Specified by:

getReportsList in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getReportsCount

public int getReportsCount()

repeated .hadoop.hdfs.StorageReportProto reports = 2;

Specified by:

getReportsCount in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getReports

public DatanodeProtocolProtos.StorageReportProto getReports(int index)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

Specified by:

getReports in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

setReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder setReports(int index,
                                                              DatanodeProtocolProtos.StorageReportProto value)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

setReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder setReports(int index,
                                                              DatanodeProtocolProtos.StorageReportProto.Builder builderForValue)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

addReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder addReports(DatanodeProtocolProtos.StorageReportProto value)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

addReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder addReports(int index,
                                                              DatanodeProtocolProtos.StorageReportProto value)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

addReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder addReports(DatanodeProtocolProtos.StorageReportProto.Builder builderForValue)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

addReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder addReports(int index,
                                                              DatanodeProtocolProtos.StorageReportProto.Builder builderForValue)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

addAllReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder addAllReports(Iterable<? extends DatanodeProtocolProtos.StorageReportProto> values)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

clearReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder clearReports()

repeated .hadoop.hdfs.StorageReportProto reports = 2;

removeReports

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder removeReports(int index)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

getReportsBuilder

public DatanodeProtocolProtos.StorageReportProto.Builder getReportsBuilder(int index)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

getReportsOrBuilder

public DatanodeProtocolProtos.StorageReportProtoOrBuilder getReportsOrBuilder(int index)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

Specified by:

getReportsOrBuilder in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getReportsOrBuilderList

public List<? extends DatanodeProtocolProtos.StorageReportProtoOrBuilder> getReportsOrBuilderList()

repeated .hadoop.hdfs.StorageReportProto reports = 2;

Specified by:

getReportsOrBuilderList in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

addReportsBuilder

public DatanodeProtocolProtos.StorageReportProto.Builder addReportsBuilder()

repeated .hadoop.hdfs.StorageReportProto reports = 2;

addReportsBuilder

public DatanodeProtocolProtos.StorageReportProto.Builder addReportsBuilder(int index)

repeated .hadoop.hdfs.StorageReportProto reports = 2;

getReportsBuilderList

public List<DatanodeProtocolProtos.StorageReportProto.Builder> getReportsBuilderList()

repeated .hadoop.hdfs.StorageReportProto reports = 2;

hasXmitsInProgress

public boolean hasXmitsInProgress()

optional uint32 xmitsInProgress = 3 [default = 0];

Specified by:

hasXmitsInProgress in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getXmitsInProgress

public int getXmitsInProgress()

optional uint32 xmitsInProgress = 3 [default = 0];

Specified by:

getXmitsInProgress in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

setXmitsInProgress

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder setXmitsInProgress(int value)

optional uint32 xmitsInProgress = 3 [default = 0];

clearXmitsInProgress

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder clearXmitsInProgress()

optional uint32 xmitsInProgress = 3 [default = 0];

hasXceiverCount

public boolean hasXceiverCount()

optional uint32 xceiverCount = 4 [default = 0];

Specified by:

hasXceiverCount in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getXceiverCount

public int getXceiverCount()

optional uint32 xceiverCount = 4 [default = 0];

Specified by:

getXceiverCount in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

setXceiverCount

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder setXceiverCount(int value)

optional uint32 xceiverCount = 4 [default = 0];

clearXceiverCount

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder clearXceiverCount()

optional uint32 xceiverCount = 4 [default = 0];

hasFailedVolumes

public boolean hasFailedVolumes()

optional uint32 failedVolumes = 5 [default = 0];

Specified by:

hasFailedVolumes in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

getFailedVolumes

public int getFailedVolumes()

optional uint32 failedVolumes = 5 [default = 0];

Specified by:

getFailedVolumes in interface DatanodeProtocolProtos.HeartbeatRequestProtoOrBuilder

setFailedVolumes

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder setFailedVolumes(int value)

optional uint32 failedVolumes = 5 [default = 0];

clearFailedVolumes

public DatanodeProtocolProtos.HeartbeatRequestProto.Builder clearFailedVolumes()

optional uint32 failedVolumes = 5 [default = 0];