Package org.apache.spark.status.protobuf

Class StoreTypes.SourceProgress

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

org.apache.spark.status.protobuf.StoreTypes.SourceProgress

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable, StoreTypes.SourceProgressOrBuilder

Enclosing class:

StoreTypes

public static final class StoreTypes.SourceProgress
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.SourceProgressOrBuilder

Protobuf type org.apache.spark.status.protobuf.SourceProgress

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	StoreTypes.SourceProgress.Builder	Protobuf type org.apache.spark.status.protobuf.SourceProgress

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage

com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DESCRIPTION_FIELD_NUMBER
static final int	END_OFFSET_FIELD_NUMBER
static final int	INPUT_ROWS_PER_SECOND_FIELD_NUMBER
static final int	LATEST_OFFSET_FIELD_NUMBER
static final int	METRICS_FIELD_NUMBER
static final int	NUM_INPUT_ROWS_FIELD_NUMBER
static final int	PROCESSED_ROWS_PER_SECOND_FIELD_NUMBER
static final int	START_OFFSET_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	containsMetrics(String key)	map<string, string> metrics = 8;
boolean	equals(Object obj)
static StoreTypes.SourceProgress	getDefaultInstance()
StoreTypes.SourceProgress	getDefaultInstanceForType()
String	getDescription()	optional string description = 1;
com.google.protobuf.ByteString	getDescriptionBytes()	optional string description = 1;
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
String	getEndOffset()	optional string end_offset = 3;
com.google.protobuf.ByteString	getEndOffsetBytes()	optional string end_offset = 3;
double	getInputRowsPerSecond()	double input_rows_per_second = 6;
String	getLatestOffset()	optional string latest_offset = 4;
com.google.protobuf.ByteString	getLatestOffsetBytes()	optional string latest_offset = 4;
Map<String,String>	getMetrics()	Deprecated.
int	getMetricsCount()	map<string, string> metrics = 8;
Map<String,String>	getMetricsMap()	map<string, string> metrics = 8;
String	getMetricsOrDefault(String key, String defaultValue)	map<string, string> metrics = 8;
String	getMetricsOrThrow(String key)	map<string, string> metrics = 8;
long	getNumInputRows()	int64 num_input_rows = 5;
com.google.protobuf.Parser<StoreTypes.SourceProgress>	getParserForType()
double	getProcessedRowsPerSecond()	double processed_rows_per_second = 7;
int	getSerializedSize()
String	getStartOffset()	optional string start_offset = 2;
com.google.protobuf.ByteString	getStartOffsetBytes()	optional string start_offset = 2;
boolean	hasDescription()	optional string description = 1;
boolean	hasEndOffset()	optional string end_offset = 3;
int	hashCode()
boolean	hasLatestOffset()	optional string latest_offset = 4;
boolean	hasStartOffset()	optional string start_offset = 2;
final boolean	isInitialized()
static StoreTypes.SourceProgress.Builder	newBuilder()
static StoreTypes.SourceProgress.Builder	newBuilder(StoreTypes.SourceProgress prototype)
StoreTypes.SourceProgress.Builder	newBuilderForType()
static StoreTypes.SourceProgress	parseDelimitedFrom(InputStream input)
static StoreTypes.SourceProgress	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.SourceProgress	parseFrom(byte[] data)
static StoreTypes.SourceProgress	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.SourceProgress	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.SourceProgress	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.SourceProgress	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.SourceProgress	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.SourceProgress	parseFrom(InputStream input)
static StoreTypes.SourceProgress	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.SourceProgress	parseFrom(ByteBuffer data)
static StoreTypes.SourceProgress	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.SourceProgress>	parser()
StoreTypes.SourceProgress.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessage

getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Field Details

DESCRIPTION_FIELD_NUMBER

public static final int DESCRIPTION_FIELD_NUMBER

See Also:

• Constant Field Values

START_OFFSET_FIELD_NUMBER

public static final int START_OFFSET_FIELD_NUMBER

See Also:

• Constant Field Values

END_OFFSET_FIELD_NUMBER

public static final int END_OFFSET_FIELD_NUMBER

See Also:

• Constant Field Values

LATEST_OFFSET_FIELD_NUMBER

public static final int LATEST_OFFSET_FIELD_NUMBER

See Also:

• Constant Field Values

NUM_INPUT_ROWS_FIELD_NUMBER

public static final int NUM_INPUT_ROWS_FIELD_NUMBER

See Also:

• Constant Field Values

INPUT_ROWS_PER_SECOND_FIELD_NUMBER

public static final int INPUT_ROWS_PER_SECOND_FIELD_NUMBER

See Also:

• Constant Field Values

PROCESSED_ROWS_PER_SECOND_FIELD_NUMBER

public static final int PROCESSED_ROWS_PER_SECOND_FIELD_NUMBER

See Also:

• Constant Field Values

METRICS_FIELD_NUMBER

public static final int METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

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

hasDescription

public boolean hasDescription()

optional string description = 1;

Specified by:

hasDescription in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the description field is set.

getDescription

public String getDescription()

optional string description = 1;

Specified by:

getDescription in interface StoreTypes.SourceProgressOrBuilder

Returns:

The description.

getDescriptionBytes

public com.google.protobuf.ByteString getDescriptionBytes()

optional string description = 1;

Specified by:

getDescriptionBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for description.

hasStartOffset

public boolean hasStartOffset()

optional string start_offset = 2;

Specified by:

hasStartOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the startOffset field is set.

getStartOffset

public String getStartOffset()

optional string start_offset = 2;

Specified by:

getStartOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

The startOffset.

getStartOffsetBytes

public com.google.protobuf.ByteString getStartOffsetBytes()

optional string start_offset = 2;

Specified by:

getStartOffsetBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for startOffset.

hasEndOffset

public boolean hasEndOffset()

optional string end_offset = 3;

Specified by:

hasEndOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the endOffset field is set.

getEndOffset

public String getEndOffset()

optional string end_offset = 3;

Specified by:

getEndOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

The endOffset.

getEndOffsetBytes

public com.google.protobuf.ByteString getEndOffsetBytes()

optional string end_offset = 3;

Specified by:

getEndOffsetBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for endOffset.

hasLatestOffset

public boolean hasLatestOffset()

optional string latest_offset = 4;

Specified by:

hasLatestOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the latestOffset field is set.

getLatestOffset

public String getLatestOffset()

optional string latest_offset = 4;

Specified by:

getLatestOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

The latestOffset.

getLatestOffsetBytes

public com.google.protobuf.ByteString getLatestOffsetBytes()

optional string latest_offset = 4;

Specified by:

getLatestOffsetBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for latestOffset.

getNumInputRows

public long getNumInputRows()

int64 num_input_rows = 5;

Specified by:

getNumInputRows in interface StoreTypes.SourceProgressOrBuilder

Returns:

The numInputRows.

getInputRowsPerSecond

public double getInputRowsPerSecond()

double input_rows_per_second = 6;

Specified by:

getInputRowsPerSecond in interface StoreTypes.SourceProgressOrBuilder

Returns:

The inputRowsPerSecond.

getProcessedRowsPerSecond

public double getProcessedRowsPerSecond()

double processed_rows_per_second = 7;

Specified by:

getProcessedRowsPerSecond in interface StoreTypes.SourceProgressOrBuilder

Returns:

The processedRowsPerSecond.

getMetricsCount

public int getMetricsCount()

Description copied from interface: StoreTypes.SourceProgressOrBuilder

map<string, string> metrics = 8;

Specified by:

getMetricsCount in interface StoreTypes.SourceProgressOrBuilder

containsMetrics

public boolean containsMetrics(String key)

map<string, string> metrics = 8;

Specified by:

containsMetrics in interface StoreTypes.SourceProgressOrBuilder

getMetrics

@Deprecated
public Map<String,String> getMetrics()

Deprecated.

Use getMetricsMap() instead.

Specified by:

getMetrics in interface StoreTypes.SourceProgressOrBuilder

getMetricsMap

public Map<String,String> getMetricsMap()

map<string, string> metrics = 8;

Specified by:

getMetricsMap in interface StoreTypes.SourceProgressOrBuilder

getMetricsOrDefault

public String getMetricsOrDefault(String key,
 String defaultValue)

map<string, string> metrics = 8;

Specified by:

getMetricsOrDefault in interface StoreTypes.SourceProgressOrBuilder

getMetricsOrThrow

public String getMetricsOrThrow(String key)

map<string, string> metrics = 8;

Specified by:

getMetricsOrThrow in interface StoreTypes.SourceProgressOrBuilder

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.GeneratedMessage

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessage

equals

public boolean equals(Object obj)

Specified by:

equals in interface com.google.protobuf.Message

Overrides:

equals in class com.google.protobuf.AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface com.google.protobuf.Message

Overrides:

hashCode in class com.google.protobuf.AbstractMessage

parseFrom

public static StoreTypes.SourceProgress parseFrom(ByteBuffer data)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.SourceProgress parseFrom(ByteBuffer data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.SourceProgress parseFrom(com.google.protobuf.ByteString data)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.SourceProgress parseFrom(com.google.protobuf.ByteString data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.SourceProgress parseFrom(byte[] data)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.SourceProgress parseFrom(byte[] data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.SourceProgress parseFrom(InputStream input)
                                           throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.SourceProgress parseFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.SourceProgress parseDelimitedFrom(InputStream input)
                                                    throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.SourceProgress parseDelimitedFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.SourceProgress parseFrom(com.google.protobuf.CodedInputStream input)
                                           throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.SourceProgress parseFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws IOException

Throws:

IOException

newBuilderForType

public StoreTypes.SourceProgress.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.SourceProgress.Builder newBuilder()

newBuilder

public static StoreTypes.SourceProgress.Builder newBuilder(StoreTypes.SourceProgress prototype)

toBuilder

public StoreTypes.SourceProgress.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.SourceProgress getDefaultInstance()

parser

public static com.google.protobuf.Parser<StoreTypes.SourceProgress> parser()

getParserForType

public com.google.protobuf.Parser<StoreTypes.SourceProgress> getParserForType()

Specified by:

getParserForType in interface com.google.protobuf.Message

Specified by:

getParserForType in interface com.google.protobuf.MessageLite

Overrides:

getParserForType in class com.google.protobuf.GeneratedMessage

getDefaultInstanceForType

public StoreTypes.SourceProgress getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder