Package com.linkedin.venice.protocols
Class IngestionMonitorResponse.Builder
java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
com.linkedin.venice.protocols.IngestionMonitorResponse.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,IngestionMonitorResponseOrBuilder,Cloneable
- Enclosing class:
- IngestionMonitorResponse
public static final class IngestionMonitorResponse.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
implements IngestionMonitorResponseOrBuilder
Protobuf type
com.linkedin.venice.protocols.IngestionMonitorResponse-
Method Summary
Modifier and TypeMethodDescriptionaddRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) build()clear()double bytes_ingested_per_sec = 5;Processing latencyTimingclearField(com.google.protobuf.Descriptors.FieldDescriptor field) bool is_hybrid = 3;double leader_bytes_produced_per_sec = 13;string leader_follower_state = 2;double leader_preprocessing_latency_avg_ms = 8;Produce latency (leader)double leader_producer_callback_latency_avg_ms = 11;double leader_producer_completion_latency_avg_ms = 10;Leader outputdouble leader_rmd_lookup_latency_avg_ms = 16;RT lookup latency (leader)clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) Ingestion throughput (measured after drainer processing / conflict resolution)Storage latencyint64 timestamp_ms = 1;clone()doubledouble bytes_ingested_per_sec = 5;doubleProcessing latencystatic final com.google.protobuf.Descriptors.Descriptorcom.google.protobuf.Descriptors.DescriptorlongTimingbooleanbool is_hybrid = 3;doubledouble leader_bytes_produced_per_sec = 13;string leader_follower_state = 2;com.google.protobuf.ByteStringstring leader_follower_state = 2;doubledouble leader_preprocessing_latency_avg_ms = 8;doubleProduce latency (leader)doubledouble leader_producer_callback_latency_avg_ms = 11;doubledouble leader_producer_completion_latency_avg_ms = 10;doubleLeader outputdoubledouble leader_rmd_lookup_latency_avg_ms = 16;doubleRT lookup latency (leader)doubleIngestion throughput (measured after drainer processing / conflict resolution)doubleStorage latencylongint64 timestamp_ms = 1;protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTablefinal booleanmergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom(com.google.protobuf.Message other) mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) setBytesIngestedPerSec(double value) double bytes_ingested_per_sec = 5;setConsumedRecordE2EProcessingLatencyAvgMs(double value) Processing latencysetElapsedTimeSinceLastRecordMs(long value) TimingsetIsHybrid(boolean value) bool is_hybrid = 3;setLeaderBytesProducedPerSec(double value) double leader_bytes_produced_per_sec = 13;setLeaderFollowerState(String value) string leader_follower_state = 2;setLeaderFollowerStateBytes(com.google.protobuf.ByteString value) string leader_follower_state = 2;setLeaderPreprocessingLatencyAvgMs(double value) double leader_preprocessing_latency_avg_ms = 8;setLeaderProduceLatencyAvgMs(double value) Produce latency (leader)setLeaderProducerCallbackLatencyAvgMs(double value) double leader_producer_callback_latency_avg_ms = 11;setLeaderProducerCompletionLatencyAvgMs(double value) double leader_producer_completion_latency_avg_ms = 10;setLeaderRecordsProducedPerSec(double value) Leader outputsetLeaderRmdLookupLatencyAvgMs(double value) double leader_rmd_lookup_latency_avg_ms = 16;setLeaderValueBytesLookupLatencyAvgMs(double value) RT lookup latency (leader)setRecordsIngestedPerSec(double value) Ingestion throughput (measured after drainer processing / conflict resolution)setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) setStorageEnginePutLatencyAvgMs(double value) Storage latencysetTimestampMs(long value) int64 timestamp_ms = 1;setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageExceptionMethods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.Message.Builder
mergeDelimitedFrom, mergeDelimitedFromMethods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFromMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
clear
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
clone
- Specified by:
clonein interfacecom.google.protobuf.Message.Builder- Specified by:
clonein interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clonein classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
setField
public IngestionMonitorResponse.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
setFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
clearField
public IngestionMonitorResponse.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) - Specified by:
clearFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
clearFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
clearOneof
public IngestionMonitorResponse.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) - Specified by:
clearOneofin interfacecom.google.protobuf.Message.Builder- Overrides:
clearOneofin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
setRepeatedField
public IngestionMonitorResponse.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) - Specified by:
setRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
addRepeatedField
public IngestionMonitorResponse.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
addRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
addRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
mergeFrom
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<IngestionMonitorResponse.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
mergeFrom
public IngestionMonitorResponse.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<IngestionMonitorResponse.Builder>- Throws:
IOException
-
getTimestampMs
public long getTimestampMs()int64 timestamp_ms = 1;- Specified by:
getTimestampMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The timestampMs.
-
setTimestampMs
int64 timestamp_ms = 1;- Parameters:
value- The timestampMs to set.- Returns:
- This builder for chaining.
-
clearTimestampMs
int64 timestamp_ms = 1;- Returns:
- This builder for chaining.
-
getLeaderFollowerState
string leader_follower_state = 2;- Specified by:
getLeaderFollowerStatein interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderFollowerState.
-
getLeaderFollowerStateBytes
public com.google.protobuf.ByteString getLeaderFollowerStateBytes()string leader_follower_state = 2;- Specified by:
getLeaderFollowerStateBytesin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The bytes for leaderFollowerState.
-
setLeaderFollowerState
string leader_follower_state = 2;- Parameters:
value- The leaderFollowerState to set.- Returns:
- This builder for chaining.
-
clearLeaderFollowerState
string leader_follower_state = 2;- Returns:
- This builder for chaining.
-
setLeaderFollowerStateBytes
public IngestionMonitorResponse.Builder setLeaderFollowerStateBytes(com.google.protobuf.ByteString value) string leader_follower_state = 2;- Parameters:
value- The bytes for leaderFollowerState to set.- Returns:
- This builder for chaining.
-
getIsHybrid
public boolean getIsHybrid()bool is_hybrid = 3;- Specified by:
getIsHybridin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The isHybrid.
-
setIsHybrid
bool is_hybrid = 3;- Parameters:
value- The isHybrid to set.- Returns:
- This builder for chaining.
-
clearIsHybrid
bool is_hybrid = 3;- Returns:
- This builder for chaining.
-
getRecordsIngestedPerSec
public double getRecordsIngestedPerSec()Ingestion throughput (measured after drainer processing / conflict resolution)
double records_ingested_per_sec = 4;- Specified by:
getRecordsIngestedPerSecin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The recordsIngestedPerSec.
-
setRecordsIngestedPerSec
Ingestion throughput (measured after drainer processing / conflict resolution)
double records_ingested_per_sec = 4;- Parameters:
value- The recordsIngestedPerSec to set.- Returns:
- This builder for chaining.
-
clearRecordsIngestedPerSec
Ingestion throughput (measured after drainer processing / conflict resolution)
double records_ingested_per_sec = 4;- Returns:
- This builder for chaining.
-
getBytesIngestedPerSec
public double getBytesIngestedPerSec()double bytes_ingested_per_sec = 5;- Specified by:
getBytesIngestedPerSecin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The bytesIngestedPerSec.
-
setBytesIngestedPerSec
double bytes_ingested_per_sec = 5;- Parameters:
value- The bytesIngestedPerSec to set.- Returns:
- This builder for chaining.
-
clearBytesIngestedPerSec
double bytes_ingested_per_sec = 5;- Returns:
- This builder for chaining.
-
getConsumedRecordE2EProcessingLatencyAvgMs
public double getConsumedRecordE2EProcessingLatencyAvgMs()Processing latency
double consumed_record_e2e_processing_latency_avg_ms = 7;- Specified by:
getConsumedRecordE2EProcessingLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The consumedRecordE2eProcessingLatencyAvgMs.
-
setConsumedRecordE2EProcessingLatencyAvgMs
Processing latency
double consumed_record_e2e_processing_latency_avg_ms = 7;- Parameters:
value- The consumedRecordE2eProcessingLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearConsumedRecordE2EProcessingLatencyAvgMs
Processing latency
double consumed_record_e2e_processing_latency_avg_ms = 7;- Returns:
- This builder for chaining.
-
getLeaderPreprocessingLatencyAvgMs
public double getLeaderPreprocessingLatencyAvgMs()double leader_preprocessing_latency_avg_ms = 8;- Specified by:
getLeaderPreprocessingLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderPreprocessingLatencyAvgMs.
-
setLeaderPreprocessingLatencyAvgMs
double leader_preprocessing_latency_avg_ms = 8;- Parameters:
value- The leaderPreprocessingLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearLeaderPreprocessingLatencyAvgMs
double leader_preprocessing_latency_avg_ms = 8;- Returns:
- This builder for chaining.
-
getLeaderProduceLatencyAvgMs
public double getLeaderProduceLatencyAvgMs()Produce latency (leader)
double leader_produce_latency_avg_ms = 9;- Specified by:
getLeaderProduceLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderProduceLatencyAvgMs.
-
setLeaderProduceLatencyAvgMs
Produce latency (leader)
double leader_produce_latency_avg_ms = 9;- Parameters:
value- The leaderProduceLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearLeaderProduceLatencyAvgMs
Produce latency (leader)
double leader_produce_latency_avg_ms = 9;- Returns:
- This builder for chaining.
-
getLeaderProducerCompletionLatencyAvgMs
public double getLeaderProducerCompletionLatencyAvgMs()double leader_producer_completion_latency_avg_ms = 10;- Specified by:
getLeaderProducerCompletionLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderProducerCompletionLatencyAvgMs.
-
setLeaderProducerCompletionLatencyAvgMs
double leader_producer_completion_latency_avg_ms = 10;- Parameters:
value- The leaderProducerCompletionLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearLeaderProducerCompletionLatencyAvgMs
double leader_producer_completion_latency_avg_ms = 10;- Returns:
- This builder for chaining.
-
getLeaderProducerCallbackLatencyAvgMs
public double getLeaderProducerCallbackLatencyAvgMs()double leader_producer_callback_latency_avg_ms = 11;- Specified by:
getLeaderProducerCallbackLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderProducerCallbackLatencyAvgMs.
-
setLeaderProducerCallbackLatencyAvgMs
double leader_producer_callback_latency_avg_ms = 11;- Parameters:
value- The leaderProducerCallbackLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearLeaderProducerCallbackLatencyAvgMs
double leader_producer_callback_latency_avg_ms = 11;- Returns:
- This builder for chaining.
-
getLeaderRecordsProducedPerSec
public double getLeaderRecordsProducedPerSec()Leader output
double leader_records_produced_per_sec = 12;- Specified by:
getLeaderRecordsProducedPerSecin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderRecordsProducedPerSec.
-
setLeaderRecordsProducedPerSec
Leader output
double leader_records_produced_per_sec = 12;- Parameters:
value- The leaderRecordsProducedPerSec to set.- Returns:
- This builder for chaining.
-
clearLeaderRecordsProducedPerSec
Leader output
double leader_records_produced_per_sec = 12;- Returns:
- This builder for chaining.
-
getLeaderBytesProducedPerSec
public double getLeaderBytesProducedPerSec()double leader_bytes_produced_per_sec = 13;- Specified by:
getLeaderBytesProducedPerSecin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderBytesProducedPerSec.
-
setLeaderBytesProducedPerSec
double leader_bytes_produced_per_sec = 13;- Parameters:
value- The leaderBytesProducedPerSec to set.- Returns:
- This builder for chaining.
-
clearLeaderBytesProducedPerSec
double leader_bytes_produced_per_sec = 13;- Returns:
- This builder for chaining.
-
getStorageEnginePutLatencyAvgMs
public double getStorageEnginePutLatencyAvgMs()Storage latency
double storage_engine_put_latency_avg_ms = 14;- Specified by:
getStorageEnginePutLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The storageEnginePutLatencyAvgMs.
-
setStorageEnginePutLatencyAvgMs
Storage latency
double storage_engine_put_latency_avg_ms = 14;- Parameters:
value- The storageEnginePutLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearStorageEnginePutLatencyAvgMs
Storage latency
double storage_engine_put_latency_avg_ms = 14;- Returns:
- This builder for chaining.
-
getLeaderValueBytesLookupLatencyAvgMs
public double getLeaderValueBytesLookupLatencyAvgMs()RT lookup latency (leader)
double leader_value_bytes_lookup_latency_avg_ms = 15;- Specified by:
getLeaderValueBytesLookupLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderValueBytesLookupLatencyAvgMs.
-
setLeaderValueBytesLookupLatencyAvgMs
RT lookup latency (leader)
double leader_value_bytes_lookup_latency_avg_ms = 15;- Parameters:
value- The leaderValueBytesLookupLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearLeaderValueBytesLookupLatencyAvgMs
RT lookup latency (leader)
double leader_value_bytes_lookup_latency_avg_ms = 15;- Returns:
- This builder for chaining.
-
getLeaderRmdLookupLatencyAvgMs
public double getLeaderRmdLookupLatencyAvgMs()double leader_rmd_lookup_latency_avg_ms = 16;- Specified by:
getLeaderRmdLookupLatencyAvgMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The leaderRmdLookupLatencyAvgMs.
-
setLeaderRmdLookupLatencyAvgMs
double leader_rmd_lookup_latency_avg_ms = 16;- Parameters:
value- The leaderRmdLookupLatencyAvgMs to set.- Returns:
- This builder for chaining.
-
clearLeaderRmdLookupLatencyAvgMs
double leader_rmd_lookup_latency_avg_ms = 16;- Returns:
- This builder for chaining.
-
getElapsedTimeSinceLastRecordMs
public long getElapsedTimeSinceLastRecordMs()Timing
int64 elapsed_time_since_last_record_ms = 17;- Specified by:
getElapsedTimeSinceLastRecordMsin interfaceIngestionMonitorResponseOrBuilder- Returns:
- The elapsedTimeSinceLastRecordMs.
-
setElapsedTimeSinceLastRecordMs
Timing
int64 elapsed_time_since_last_record_ms = 17;- Parameters:
value- The elapsedTimeSinceLastRecordMs to set.- Returns:
- This builder for chaining.
-
clearElapsedTimeSinceLastRecordMs
Timing
int64 elapsed_time_since_last_record_ms = 17;- Returns:
- This builder for chaining.
-
setUnknownFields
public final IngestionMonitorResponse.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
setUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
setUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-
mergeUnknownFields
public final IngestionMonitorResponse.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
mergeUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<IngestionMonitorResponse.Builder>
-