Serialized Form

Package com.linkedin.alpini.base.misc

Class com.linkedin.alpini.base.misc.ExceptionWithStatus extends java.lang.Exception implements Serializable

Serialized Fields

_code

int _code

_status

java.lang.Object _status

_statusClass

java.lang.Class<?> _statusClass

Class com.linkedin.alpini.base.misc.Http2TooManyStreamsException extends java.lang.Exception implements Serializable

Package com.linkedin.alpini.netty4.handlers

Class com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec.ResponseOutOfSequence extends io.netty.handler.codec.EncoderException implements Serializable

Package com.linkedin.alpini.netty4.misc

Class com.linkedin.alpini.netty4.misc.ExceptionWithResponseStatus extends ExceptionWithStatus implements Serializable

Package com.linkedin.alpini.netty4.ssl

Class com.linkedin.alpini.netty4.ssl.FusedSslHandler.OverflowException extends java.io.IOException implements Serializable

Class com.linkedin.alpini.netty4.ssl.SSLEngineFactoryImpl.ConfigHelper.MissingConfigParameterException extends java.lang.IllegalArgumentException implements Serializable

Package com.linkedin.alpini.router.api

Class com.linkedin.alpini.router.api.Netty4RouterException extends RouterException implements Serializable

Class com.linkedin.alpini.router.api.RouterException extends ExceptionWithStatus implements Serializable

serialVersionUID:

1L

Serialized Fields

_closeChannel

boolean _closeChannel

Package com.linkedin.avro.fastserde

Class com.linkedin.avro.fastserde.FastAvroConcurrentHashMap extends java.util.concurrent.ConcurrentHashMap<K extends java.lang.Object,V extends java.lang.Object> implements Serializable

Class com.linkedin.avro.fastserde.FastDeserializerGeneratorException extends java.lang.RuntimeException implements Serializable

serialVersionUID:

1L

Class com.linkedin.avro.fastserde.FastSerdeGeneratorException extends java.lang.RuntimeException implements Serializable

Class com.linkedin.avro.fastserde.SchemaAssistantException extends java.lang.RuntimeException implements Serializable

Package com.linkedin.davinci.client

Class com.linkedin.davinci.client.NonLocalAccessException extends VeniceClientException implements Serializable

Package com.linkedin.davinci.consumer

Class com.linkedin.davinci.consumer.VeniceChangeCoordinate extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException,
                         java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.davinci.consumer.VeniceCoordinateOutOfRangeException extends VeniceException implements Serializable

Package com.linkedin.davinci.schema.writecompute

Class com.linkedin.davinci.schema.writecompute.WriteComputeSchemaValidator.InvalidWriteComputeException extends VeniceException implements Serializable

Package com.linkedin.davinci.store

Class com.linkedin.davinci.store.StorageEngineInitializationException extends VeniceException implements Serializable

serialVersionUID:

1L

Class com.linkedin.davinci.store.StoragePartitionInitializationException extends VeniceException implements Serializable

serialVersionUID:

1L

Package com.linkedin.venice.acl

Class com.linkedin.venice.acl.AclException extends java.lang.Exception implements Serializable

Package com.linkedin.venice.admin.protocol.response

Class com.linkedin.venice.admin.protocol.response.AdminResponseRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

5761101675693128371L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.admin.protocol.response.ConsumptionStateSnapshot extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4602111247704740063L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.admin.protocol.response.ServerConfigSnapshot extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

6724605933807082490L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.beam.consumer

Class com.linkedin.venice.beam.consumer.LocalVeniceChangelogConsumerProvider extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

_veniceChangelogConsumerClientFactoryClass

java.lang.Class<? extends VeniceChangelogConsumerClientFactory> _veniceChangelogConsumerClientFactoryClass

Class com.linkedin.venice.beam.consumer.PubSubMessageCoder extends org.apache.beam.sdk.coders.StructuredCoder<PubSubMessage<K,ChangeEvent<V>,VeniceChangeCoordinate>> implements Serializable

serialVersionUID:

1L

Serialized Fields

pubSubMessageAvroCoder

org.apache.beam.sdk.extensions.avro.coders.AvroCoder<PubSubMessage<K,ChangeEvent<V>,VeniceChangeCoordinate>> pubSubMessageAvroCoder

Class com.linkedin.venice.beam.consumer.VeniceChangelogConsumerIO.Read extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<PubSubMessage<K,ChangeEvent<V>,VeniceChangeCoordinate>>> implements Serializable

serialVersionUID:

1L

Serialized Fields

consumerIdSuffix

java.lang.String consumerIdSuffix

localVeniceChangelogConsumerProvider

LocalVeniceChangelogConsumerProvider localVeniceChangelogConsumerProvider

partitions

java.util.Set<java.lang.Integer> partitions

pollTimeout

org.joda.time.Duration pollTimeout

seekTimestamp

long seekTimestamp

seekWhence

VeniceChangelogConsumerIO.Read.SeekWhence seekWhence

store

java.lang.String store

terminationTimeout

org.joda.time.Duration terminationTimeout

Class com.linkedin.venice.beam.consumer.VeniceCheckpointMark.Coder extends org.apache.beam.sdk.coders.AtomicCoder<VeniceCheckpointMark> implements Serializable

serialVersionUID:

1L

Serialized Fields

_sizeCoder

org.apache.beam.sdk.coders.VarIntCoder _sizeCoder

_stringUtf8Coder

org.apache.beam.sdk.coders.StringUtf8Coder _stringUtf8Coder

Class com.linkedin.venice.beam.consumer.VeniceMessageCoder extends org.apache.beam.sdk.coders.StructuredCoder<org.apache.beam.sdk.values.KV<K,ChangeEvent<V>>> implements Serializable

serialVersionUID:

1L

Serialized Fields

_kvCoder

org.apache.beam.sdk.coders.KvCoder<K,java.util.List<V>> _kvCoder

keyCoder

org.apache.beam.sdk.extensions.avro.coders.AvroCoder<K> keyCoder

listCoder

org.apache.beam.sdk.coders.ListCoder<V> listCoder

valueCoder

org.apache.beam.sdk.extensions.avro.coders.AvroCoder<V> valueCoder

Package com.linkedin.venice.client.change.capture.protocol

Class com.linkedin.venice.client.change.capture.protocol.RecordChangeEvent extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4124505617846281396L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.client.change.capture.protocol.ValueBytes extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-7598697125532667570L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.client.exceptions

Class com.linkedin.venice.client.exceptions.ServiceDiscoveryException extends VeniceClientException implements Serializable

Class com.linkedin.venice.client.exceptions.VeniceClientException extends VeniceException implements Serializable

Class com.linkedin.venice.client.exceptions.VeniceClientHttpException extends VeniceClientException implements Serializable

Serialized Fields

httpStatus

int httpStatus

Class com.linkedin.venice.client.exceptions.VeniceClientRateExceededException extends VeniceClientHttpException implements Serializable

Package com.linkedin.venice.client.store.schemas

Class com.linkedin.venice.client.store.schemas.TestKeyRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput arg0)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput arg0)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.client.store.schemas.TestValueRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput arg0)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput arg0)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.client.store.schemas.TestValueRecordWithMoreFields extends org.apache.avro.specific.SpecificRecordBase implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput arg0)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput arg0)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.client.store.streaming

Class com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer.NotEnoughBytesException extends java.lang.Exception implements Serializable

Class com.linkedin.venice.client.store.streaming.VeniceResponseMapImpl extends java.util.HashMap<K,V> implements Serializable

serialVersionUID:

1L

Serialized Fields

fullResponse

boolean fullResponse

nonExistingKeys

java.util.Set<K> nonExistingKeys

Package com.linkedin.venice.compression.protocol

Class com.linkedin.venice.compression.protocol.FakeCompressingSchema extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4216097061218321773L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.compute.protocol.request

Class com.linkedin.venice.compute.protocol.request.ComputeOperation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

1058520520149010710L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.ComputeRequest extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

5035797444789178955L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.ComputeRequestV1 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-936291794305168013L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.ComputeRequestV2 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5285908897347269717L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.ComputeRequestV3 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8486958835725153821L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.ComputeRequestV4 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4462725568814220827L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.CosineSimilarity extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-9188492108529286547L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.Count extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6654918846552929921L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.DotProduct extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

2594291556121726255L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.compute.protocol.request.HadamardProduct extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4373124732804948143L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.compute.protocol.request.router

Class com.linkedin.venice.compute.protocol.request.router.ComputeRouterRequestKeyV1 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4281766436911660257L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.compute.protocol.response

Class com.linkedin.venice.compute.protocol.response.ComputeResponseRecordV1 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-3637528416416965416L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.controller.exception

Class com.linkedin.venice.controller.exception.HelixClusterMaintenanceModeException extends VeniceException implements Serializable

Package com.linkedin.venice.controller.kafka.protocol.admin

Class com.linkedin.venice.controller.kafka.protocol.admin.AbortMigration extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-7742296756716399551L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.AddVersion extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

257658592603009416L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-2547633646200222959L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.ConfigureActiveActiveReplicationForCluster extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

1754070675534614012L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.ConfigureIncrementalPushForCluster extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8698705926059766853L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.ConfigureNativeReplicationForCluster extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4167226100097952693L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.CreateStoragePersona extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

6740577141833147284L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.DeleteAllVersions extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8072594770977476639L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.DeleteOldVersion extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

1215291246646587145L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.DeleteStoragePersona extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

6623011002810696177L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.DeleteStore extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4591429945995995006L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.DeleteUnusedValueSchemas extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8603551652339347376L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.DerivedSchemaCreation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8878195732301070844L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.DisableStoreRead extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-920977876894325613L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.EnableStoreRead extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1267789310964944844L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.ETLStoreConfigRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

2292293113739011415L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.HybridStoreConfigRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8729483687668846545L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.KillOfflinePushJob extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-9114863684654242414L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.MetadataSchemaCreation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

5236514718865075092L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.MetaSystemStoreAutoCreationValidation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6259330010023241299L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.MigrateStore extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-2748439851566632405L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.PartitionerConfigRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4386728759893759468L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.PauseStore extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

9075160214986248303L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.PushStatusSystemStoreAutoCreationValidation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8610863510522801988L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.ResumeStore extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

6351085370557585029L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.RollbackCurrentVersion extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

7756498062766816034L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.RollForwardCurrentVersion extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-2587775651125933438L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.SchemaMeta extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-693421538839533103L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.SetStoreCurrentVersion extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6296217683467718491L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.SetStoreOwner extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

7820573927951334740L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.SetStorePartitionCount extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

594460189223428549L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.StoreCreation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1173065906041385139L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.StoreViewConfigRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4929852317453019863L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.SupersetSchemaCreation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1311029237566773365L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStoragePersona extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4372262333105325819L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

7138619503700654313L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.controller.kafka.protocol.admin.ValueSchemaCreation extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6318199461248512171L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.etl

Class com.linkedin.venice.etl.VeniceKafkaDecodedRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4589312864521446835L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.exceptions

Class com.linkedin.venice.exceptions.ConcurrentBatchPushException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.ConfigurationException extends VeniceException implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.exceptions.DiskLimitExhaustedException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.InvalidVeniceSchemaException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.KafkaConsumerException extends VeniceException implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.exceptions.MemoryLimitExhaustedException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.MissingKeyInStoreMetadataException extends VeniceException implements Serializable

Serialized Fields

keyName

java.lang.String keyName

metadataClassName

java.lang.String metadataClassName

Class com.linkedin.venice.exceptions.OperationNotAllowedException extends VeniceHttpException implements Serializable

Class com.linkedin.venice.exceptions.PartitionerSchemaMismatchException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.PersistenceFailureException extends VeniceException implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.exceptions.QuotaExceededException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.RecordTooLargeException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.ResourceStillExistsException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.SchemaDuplicateException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.SchemaIncompatibilityException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.StorageInitializationException extends VeniceException implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.exceptions.StoreDisabledException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.StoreKeySchemaExistException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.StoreVersionNotFoundException extends VeniceNoStoreException implements Serializable

Class com.linkedin.venice.exceptions.UndefinedPropertyException extends ConfigurationException implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.exceptions.VeniceAclException extends VeniceException implements Serializable

Serialized Fields

httpErrorCode

int httpErrorCode

Class com.linkedin.venice.exceptions.VeniceBlobTransferFileNotFoundException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceChecksumException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceException extends java.lang.RuntimeException implements Serializable

serialVersionUID:

1L

Serialized Fields

errorType

ErrorType errorType

Class com.linkedin.venice.exceptions.VeniceHttpException extends VeniceException implements Serializable

Serialized Fields

statusCode

int statusCode

Class com.linkedin.venice.exceptions.VeniceInconsistentStoreMetadataException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceIngestionTaskKilledException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceMessageException extends VeniceException implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.exceptions.VeniceNoClusterException extends VeniceException implements Serializable

Serialized Fields

clusterName

java.lang.String clusterName

Class com.linkedin.venice.exceptions.VeniceNoHelixResourceException extends VeniceRouterException implements Serializable

Serialized Fields

resource

java.lang.String resource

version

int version

Class com.linkedin.venice.exceptions.VeniceNoStoreException extends VeniceException implements Serializable

Serialized Fields

clusterName

java.lang.String clusterName

storeName

java.lang.String storeName

Class com.linkedin.venice.exceptions.VenicePeersConnectionException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VenicePeersNotFoundException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceResourceAccessException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceRetriableException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceRouterException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.VeniceStoreAlreadyExistsException extends VeniceException implements Serializable

Serialized Fields

clusterName

java.lang.String clusterName

storeName

java.lang.String storeName

Class com.linkedin.venice.exceptions.VeniceStoreIsMigratedException extends VeniceException implements Serializable

Serialized Fields

clusterName

java.lang.String clusterName

d2ServiceName

java.lang.String d2ServiceName

storeName

java.lang.String storeName

Class com.linkedin.venice.exceptions.VeniceTimeoutException extends VeniceRetriableException implements Serializable

Class com.linkedin.venice.exceptions.VeniceUnsupportedOperationException extends VeniceException implements Serializable

Class com.linkedin.venice.exceptions.ZkDataAccessException extends VeniceException implements Serializable

Package com.linkedin.venice.exceptions.validation

Class com.linkedin.venice.exceptions.validation.CorruptDataException extends FatalDataValidationException implements Serializable

Class com.linkedin.venice.exceptions.validation.DataValidationException extends KafkaConsumerException implements Serializable

Class com.linkedin.venice.exceptions.validation.DuplicateDataException extends DataValidationException implements Serializable

Class com.linkedin.venice.exceptions.validation.FatalDataValidationException extends DataValidationException implements Serializable

Class com.linkedin.venice.exceptions.validation.ImproperlyStartedSegmentException extends MissingDataException implements Serializable

Class com.linkedin.venice.exceptions.validation.IncomingDataAfterSegmentEndedException extends FatalDataValidationException implements Serializable

Class com.linkedin.venice.exceptions.validation.MissingDataException extends FatalDataValidationException implements Serializable

Class com.linkedin.venice.exceptions.validation.UnsupportedMessageTypeException extends CorruptDataException implements Serializable

Package com.linkedin.venice.hadoop

Class com.linkedin.venice.hadoop.PushJobSetting extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

batchNumBytes

int batchNumBytes

childControllerRegionD2ZkHosts

java.lang.String childControllerRegionD2ZkHosts

chunkingEnabled

boolean chunkingEnabled

clusterName

java.lang.String clusterName

compressionMetricCollectionEnabled

boolean compressionMetricCollectionEnabled

Refer VenicePushJobConstants.COMPRESSION_METRIC_COLLECTION_ENABLED

controllerD2ServiceName

java.lang.String controllerD2ServiceName

controllerRetries

int controllerRetries

controllerStatusPollRetries

int controllerStatusPollRetries

d2Routing

boolean d2Routing

dataWriterComputeJobClass

java.lang.Class<? extends DataWriterComputeJob> dataWriterComputeJobClass

deferVersionSwap

boolean deferVersionSwap

derivedSchemaId

int derivedSchemaId

enablePushJobStatusUpload

boolean enablePushJobStatusUpload

enableSSL

boolean enableSSL

enableWriteCompute

boolean enableWriteCompute

etlValueSchemaTransformation

ETLValueSchemaTransformation etlValueSchemaTransformation

extendedSchemaValidityCheckEnabled

boolean extendedSchemaValidityCheckEnabled

generatePartialUpdateRecordFromInput

boolean generatePartialUpdateRecordFromInput

incrementalPushVersion

java.lang.String incrementalPushVersion

inputDataSchema

org.apache.avro.Schema inputDataSchema

inputDataSchemaString

java.lang.String inputDataSchemaString

inputFileDataSizeInBytes

long inputFileDataSizeInBytes

inputHasRecords

boolean inputHasRecords

inputURI

java.lang.String inputURI

isAvro

boolean isAvro

isChunkingEnabled

boolean isChunkingEnabled

isDuplicateKeyAllowed

boolean isDuplicateKeyAllowed

isIncrementalPush

boolean isIncrementalPush

isRmdChunkingEnabled

boolean isRmdChunkingEnabled

isSchemaAutoRegisterFromPushJobEnabled

boolean isSchemaAutoRegisterFromPushJobEnabled

isSourceETL

boolean isSourceETL

isSourceKafka

boolean isSourceKafka

isStoreIncrementalPushEnabled

boolean isStoreIncrementalPushEnabled

isStoreWriteComputeEnabled

boolean isStoreWriteComputeEnabled

isSystemSchemaReaderEnabled

boolean isSystemSchemaReaderEnabled

isTargetedRegionPushEnabled

boolean isTargetedRegionPushEnabled

isTargetRegionPushWithDeferredSwapEnabled

boolean isTargetRegionPushWithDeferredSwapEnabled

isZstdDictCreationRequired

boolean isZstdDictCreationRequired

isZstdDictCreationSuccess

boolean isZstdDictCreationSuccess

jobExecutionId

java.lang.String jobExecutionId

jobId

java.lang.String jobId

jobServerName

java.lang.String jobServerName

jobStartTimeMs

long jobStartTimeMs

jobStatusInUnknownStateTimeoutMs

long jobStatusInUnknownStateTimeoutMs

jobTmpDir

java.lang.String jobTmpDir

kafkaInputBrokerUrl

java.lang.String kafkaInputBrokerUrl

kafkaInputBuildNewDictEnabled

boolean kafkaInputBuildNewDictEnabled

kafkaInputCombinerEnabled

boolean kafkaInputCombinerEnabled

kafkaInputTopic

java.lang.String kafkaInputTopic

kafkaSourceRegion

java.lang.String kafkaSourceRegion

kafkaUrl

java.lang.String kafkaUrl

keyField

java.lang.String keyField

keySchema

org.apache.avro.Schema keySchema

keySchemaString

java.lang.String keySchemaString

livenessHeartbeatEnabled

boolean livenessHeartbeatEnabled

livenessHeartbeatStoreName

java.lang.String livenessHeartbeatStoreName

maxRecordSizeBytes

int maxRecordSizeBytes

multiRegion

boolean multiRegion

parentControllerRegionD2ZkHosts

java.lang.String parentControllerRegionD2ZkHosts

partitionCount

int partitionCount

partitionerClass

java.lang.String partitionerClass

partitionerParams

java.util.Map<java.lang.String,java.lang.String> partitionerParams

pollJobStatusIntervalMs

long pollJobStatusIntervalMs

pushToSeparateRealtimeTopicEnabled

boolean pushToSeparateRealtimeTopicEnabled

repushSourceVersion

int repushSourceVersion

repushTTLEnabled

boolean repushTTLEnabled

repushTTLStartTimeMs

long repushTTLStartTimeMs

rewindTimeInSecondsOverride

long rewindTimeInSecondsOverride

rmdChunkingEnabled

boolean rmdChunkingEnabled

rmdSchemaDir

java.lang.String rmdSchemaDir

sendControlMessagesDirectly

boolean sendControlMessagesDirectly

sharedTmpDir

java.lang.String sharedTmpDir

sourceGridFabric

java.lang.String sourceGridFabric

sourceVersionChunkingEnabled

boolean sourceVersionChunkingEnabled

sourceVersionCompressionStrategy

CompressionStrategy sourceVersionCompressionStrategy

sslToKafka

boolean sslToKafka

storeCompressionStrategy

CompressionStrategy storeCompressionStrategy

storeKeySchema

org.apache.avro.Schema storeKeySchema

storeName

java.lang.String storeName

storeStorageQuota

long storeStorageQuota

suppressEndOfPushMessage

boolean suppressEndOfPushMessage

systemSchemaClusterD2ServiceName

java.lang.String systemSchemaClusterD2ServiceName

systemSchemaClusterD2ZKHost

java.lang.String systemSchemaClusterD2ZKHost

targetedRegions

java.lang.String targetedRegions

topic

java.lang.String topic

topicCompressionStrategy

CompressionStrategy topicCompressionStrategy

useMapperToBuildDict

boolean useMapperToBuildDict

Refer VenicePushJobConstants.USE_MAPPER_TO_BUILD_DICTIONARY

validateRemoteReplayPolicy

BufferReplayPolicy validateRemoteReplayPolicy

valueField

java.lang.String valueField

valueSchema

org.apache.avro.Schema valueSchema

valueSchemaDir

java.lang.String valueSchemaDir

valueSchemaId

int valueSchemaId

valueSchemaString

java.lang.String valueSchemaString

veniceControllerUrl

java.lang.String veniceControllerUrl

version

int version

Version part of the store-version / topic name

vpjEntryClass

java.lang.Class<? extends VenicePushJob> vpjEntryClass

vsonInputKeySchema

VsonSchema vsonInputKeySchema

vsonInputKeySchemaString

java.lang.String vsonInputKeySchemaString

vsonInputValueSchema

VsonSchema vsonInputValueSchema

vsonInputValueSchemaString

java.lang.String vsonInputValueSchemaString

Package com.linkedin.venice.hadoop.exceptions

Class com.linkedin.venice.hadoop.exceptions.VeniceInconsistentSchemaException extends VeniceException implements Serializable

Class com.linkedin.venice.hadoop.exceptions.VeniceSchemaFieldNotFoundException extends VeniceException implements Serializable

Serialized Fields

fieldName

java.lang.String fieldName

Class com.linkedin.venice.hadoop.exceptions.VeniceStoreCreationException extends VeniceException implements Serializable

Serialized Fields

storeName

java.lang.String storeName

Class com.linkedin.venice.hadoop.exceptions.VeniceValidationException extends VeniceException implements Serializable

Package com.linkedin.venice.hadoop.input.kafka

Class com.linkedin.venice.hadoop.input.kafka.KafkaInputKeyComparator extends java.lang.Object implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.hadoop.input.kafka.KafkaInputValueGroupingComparator extends KafkaInputKeyComparator implements Serializable

serialVersionUID:

1L

Package com.linkedin.venice.hadoop.input.kafka.avro

Class com.linkedin.venice.hadoop.input.kafka.avro.KafkaInputMapperKey extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

5538508172634308478L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.hadoop.input.kafka.avro.KafkaInputMapperValue extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4910625535217701229L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.hadoop.output.avro

Class com.linkedin.venice.hadoop.output.avro.ValidateSchemaAndBuildDictMapperOutput extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-7701303845483798833L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.ingestion.control

Class com.linkedin.venice.ingestion.control.DuplicateTopicException extends VeniceException implements Serializable

Package com.linkedin.venice.ingestion.protocol

Class com.linkedin.venice.ingestion.protocol.IngestionMetricsReport extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5878893562914495221L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.ingestion.protocol.IngestionStorageMetadata extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5384228618089453893L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.ingestion.protocol.IngestionTaskCommand extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-9176705459973240370L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.ingestion.protocol.IngestionTaskReport extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6568008902004261297L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.ingestion.protocol.LoadedStoreUserPartitionMapping extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1636215181242447934L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.ingestion.protocol.ProcessShutdownCommand extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

3657549379016066961L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.kafka.protocol

Class com.linkedin.venice.kafka.protocol.ControlMessage extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8532391313761890626L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.Delete extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4107303321109090389L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.EndOfIncrementalPush extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1445632741261320015L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.EndOfPush extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4003892792165692916L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.EndOfSegment extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5920076414965370039L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.GUID extends org.apache.avro.specific.SpecificFixed implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.KafkaMessageEnvelope extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8699300686147399293L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.LeaderMetadata extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

7836207590331712101L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.ProducerMetadata extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4659296984332473126L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.Put extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5569758952499376058L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.StartOfBufferReplay extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

9010138765721059647L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.StartOfIncrementalPush extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

1337521134574787694L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.StartOfPush extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1853024095552748608L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.StartOfSegment extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4246982350298302856L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.TopicSwitch extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5740502939082925729L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.Update extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-406433932799465134L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.VersionSwap extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-3783906363462869061L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.kafka.protocol.state

Class com.linkedin.venice.kafka.protocol.state.IncrementalPush extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-2935710582474967181L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.state.PartitionState extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

6737586236421941612L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.state.ProducerPartitionState extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8935563812651224467L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.kafka.protocol.state.StoreVersionState extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

5464674299228142723L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.listener

Class com.linkedin.venice.listener.VeniceRequestEarlyTerminationException extends VeniceException implements Serializable

Serialized Fields

storeName

java.lang.String storeName

Package com.linkedin.venice.meta.systemstore.schemas

Class com.linkedin.venice.meta.systemstore.schemas.CurrentStoreStates extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5128047373658710394L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.CurrentVersionStates extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

629411344499000739L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.ETLStoreConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

386615025391165847L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.HybridStoreConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

7473400723220428777L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.PartitionerConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5265755630831617332L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.StoreAttributes extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

5104876172429937575L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.StoreKeySchemas extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-2934197998845380869L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.StoreMetadataKey extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1334839667646732363L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.StoreMetadataValue extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-9135862411773726654L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.StoreProperties extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1802296258588938995L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.StoreValueSchemas extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5679399156358118730L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.StoreVersionState extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5195737296664976852L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.meta.systemstore.schemas.TargetVersionStates extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

9193702374697293247L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.metadata.response

Class com.linkedin.venice.metadata.response.MetadataResponseRecord extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

2383786821899158742L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.metadata.response.VersionProperties extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1824849756083326443L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.participant.protocol

Class com.linkedin.venice.participant.protocol.KillPushJob extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4063173186862784375L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.participant.protocol.ParticipantMessageKey extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6485568257730176435L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.participant.protocol.ParticipantMessageValue extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4874599879507206794L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.protocols

Class com.linkedin.venice.protocols.VeniceClientRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable

serialVersionUID:

0L

Serialized Fields

isBatchRequest_

boolean isBatchRequest_

isRetryRequest_

boolean isRetryRequest_

isStreamingRequest_

boolean isStreamingRequest_

keyBytes_

com.google.protobuf.ByteString keyBytes_

keyString_

java.lang.Object keyString_

memoizedIsInitialized

byte memoizedIsInitialized

method_

java.lang.Object method_

partition_

int partition_

resourceName_

java.lang.Object resourceName_

Class com.linkedin.venice.protocols.VeniceServerResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable

serialVersionUID:

0L

Serialized Fields

compressionStrategy_

int compressionStrategy_

data_

com.google.protobuf.ByteString data_

errorCode_

int errorCode_

errorMessage_

java.lang.Object errorMessage_

isStreamingResponse_

boolean isStreamingResponse_

memoizedIsInitialized

byte memoizedIsInitialized

responseRCU_

int responseRCU_

schemaId_

int schemaId_

Package com.linkedin.venice.pubsub.api

Class com.linkedin.venice.pubsub.api.PubSubPositionWireFormat extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1143464011218848508L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.pubsub.api.exceptions

Class com.linkedin.venice.pubsub.api.exceptions.PubSubClientException extends VeniceException implements Serializable

Class com.linkedin.venice.pubsub.api.exceptions.PubSubClientRetriableException extends VeniceRetriableException implements Serializable

Class com.linkedin.venice.pubsub.api.exceptions.PubSubOpTimeoutException extends PubSubClientRetriableException implements Serializable

Class com.linkedin.venice.pubsub.api.exceptions.PubSubTopicAuthorizationException extends PubSubClientException implements Serializable

Class com.linkedin.venice.pubsub.api.exceptions.PubSubTopicDoesNotExistException extends PubSubClientRetriableException implements Serializable

Class com.linkedin.venice.pubsub.api.exceptions.PubSubTopicExistsException extends PubSubClientException implements Serializable

Class com.linkedin.venice.pubsub.api.exceptions.PubSubUnsubscribedTopicPartitionException extends PubSubClientException implements Serializable

Package com.linkedin.venice.pulsar.sink

Class com.linkedin.venice.pulsar.sink.VenicePulsarSinkConfig extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

flushIntervalMs

long flushIntervalMs

kafkaSaslConfig

java.lang.String kafkaSaslConfig

kafkaSaslMechanism

java.lang.String kafkaSaslMechanism

kafkaSecurityProtocol

java.lang.String kafkaSecurityProtocol

maxNumberUnflushedRecords

int maxNumberUnflushedRecords

storeName

java.lang.String storeName

veniceDiscoveryUrl

java.lang.String veniceDiscoveryUrl

veniceRouterUrl

java.lang.String veniceRouterUrl

writerConfig

java.util.Map<java.lang.String,java.lang.String> writerConfig

Package com.linkedin.venice.pushstatus

Class com.linkedin.venice.pushstatus.PushStatusKey extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1077248654244901549L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.pushstatus.PushStatusValue extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1161703101625203416L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.read.protocol.request.router

Class com.linkedin.venice.read.protocol.request.router.MultiGetRouterRequestKeyV1 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-4292765688184143483L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.read.protocol.response

Class com.linkedin.venice.read.protocol.response.MultiGetResponseRecordV1 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1339531883776153861L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.read.protocol.response.streaming

Class com.linkedin.venice.read.protocol.response.streaming.StreamingFooterRecordV1 extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5265532689528729697L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.router.exception

Class com.linkedin.venice.router.exception.VeniceKeyCountLimitException extends VeniceException implements Serializable

Serialized Fields

requestKeyCount

int requestKeyCount

requestType

RequestType requestType

storeName

java.lang.String storeName

Package com.linkedin.venice.samza

Class com.linkedin.venice.samza.VeniceSystemFactory extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

systemProducerStatues

java.util.Map<org.apache.samza.system.SystemProducer,Pair<java.lang.Boolean,java.lang.Boolean>> systemProducerStatues

Key: VeniceSystemProducer instance; Value: a pair of boolean: For each SystemProducer created through this factory, keep track of its status in the below Map. RouterBasedPushMonitor will update the status of the SystemProducer.

Package com.linkedin.venice.schema.vson

Class com.linkedin.venice.schema.vson.VsonAvroDatumReader.DeepEqualsArrayList extends java.util.ArrayList<java.lang.Object> implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.schema.vson.VsonAvroDatumReader.DeepEqualsHashMap extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.schema.vson.VsonSchema extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

type

java.lang.Object type

Deprecated.

Package com.linkedin.venice.security

Class com.linkedin.venice.security.SSLConfig.ConfigHelper.MissingConfigParameterException extends java.lang.IllegalArgumentException implements Serializable

Package com.linkedin.venice.serializer

Class com.linkedin.venice.serializer.VeniceSerializationException extends VeniceException implements Serializable

Class com.linkedin.venice.serializer.VsonSerializationException extends VeniceException implements Serializable

Package com.linkedin.venice.spark.datawriter.partition

Class com.linkedin.venice.spark.datawriter.partition.PartitionSorter extends java.lang.Object implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.spark.datawriter.partition.VeniceSparkPartitioner extends org.apache.spark.Partitioner implements Serializable

serialVersionUID:

1L

Serialized Fields

broadcastProperties

org.apache.spark.broadcast.Broadcast<java.util.Properties> broadcastProperties

numPartitions

int numPartitions

Package com.linkedin.venice.spark.datawriter.recordprocessor

Class com.linkedin.venice.spark.datawriter.recordprocessor.SparkInputRecordProcessorFactory extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

accumulators

DataWriterAccumulators accumulators

jobProps

org.apache.spark.broadcast.Broadcast<java.util.Properties> jobProps

Package com.linkedin.venice.spark.datawriter.task

Class com.linkedin.venice.spark.datawriter.task.DataWriterAccumulators extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

compressedValueSizeCounter

org.apache.spark.util.LongAccumulator compressedValueSizeCounter

duplicateKeyWithDistinctValueCounter

org.apache.spark.util.LongAccumulator duplicateKeyWithDistinctValueCounter

duplicateKeyWithIdenticalValueCounter

org.apache.spark.util.LongAccumulator duplicateKeyWithIdenticalValueCounter

emptyRecordCounter

org.apache.spark.util.LongAccumulator emptyRecordCounter

gzipCompressedValueSizeCounter

org.apache.spark.util.LongAccumulator gzipCompressedValueSizeCounter

outputRecordCounter

org.apache.spark.util.LongAccumulator outputRecordCounter

partitionWriterCloseCounter

org.apache.spark.util.LongAccumulator partitionWriterCloseCounter

recordTooLargeFailureCounter

org.apache.spark.util.LongAccumulator recordTooLargeFailureCounter

repushTtlFilteredRecordCounter

org.apache.spark.util.LongAccumulator repushTtlFilteredRecordCounter

sprayAllPartitionsTriggeredCount

org.apache.spark.util.LongAccumulator sprayAllPartitionsTriggeredCount

totalKeySizeCounter

org.apache.spark.util.LongAccumulator totalKeySizeCounter

uncompressedValueSizeCounter

org.apache.spark.util.LongAccumulator uncompressedValueSizeCounter

writeAclAuthorizationFailureCounter

org.apache.spark.util.LongAccumulator writeAclAuthorizationFailureCounter

zstdCompressedValueSizeCounter

org.apache.spark.util.LongAccumulator zstdCompressedValueSizeCounter

Package com.linkedin.venice.spark.datawriter.writer

Class com.linkedin.venice.spark.datawriter.writer.SparkPartitionWriterFactory extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

accumulators

DataWriterAccumulators accumulators

jobProps

org.apache.spark.broadcast.Broadcast<java.util.Properties> jobProps

Package com.linkedin.venice.spark.input.hdfs

Class com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputPartition extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

filePathURI

java.net.URI filePathURI

Class com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputPartitionReaderFactory extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

jobConfig

VeniceProperties jobConfig

Package com.linkedin.venice.status.protocol

Class com.linkedin.venice.status.protocol.BatchJobHeartbeatKey extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

3641239702220214112L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.status.protocol.BatchJobHeartbeatValue extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

3964758583432955202L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.status.protocol.PushJobDetails extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8493479868717346395L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.status.protocol.PushJobDetailsStatusTuple extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8748825183356649810L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.status.protocol.PushJobStatusRecordKey extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8756503431514842211L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.storage.protocol

Class com.linkedin.venice.storage.protocol.ChunkedKeySuffix extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

556587138401303468L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.storage.protocol.ChunkedValueManifest extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8111551772284562083L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.storage.protocol.ChunkId extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4013130109663765556L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.store.exception

Class com.linkedin.venice.store.exception.InvalidDatabaseNameException extends VeniceException implements Serializable

Package com.linkedin.venice.systemstore.schemas

Class com.linkedin.venice.systemstore.schemas.DataRecoveryConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8635018859291271327L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreClusterConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8366194660284966595L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreETLConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5446769225069350281L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreHybridConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5013815664427103704L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreKeySchemas extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-1510578967185446890L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreMetaKey extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-5266781807689106608L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreMetaValue extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8125627235713545258L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StorePartitionerConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-8369875847945101544L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreProperties extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

4058695681344329845L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreReplicaStatus extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6150276810359697155L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreValueSchema extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-2622307728512171089L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreValueSchemas extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-3258276091728819974L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreVersion extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

6310049090904030280L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.StoreViewConfig extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

8990245963340696629L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Class com.linkedin.venice.systemstore.schemas.SystemStoreProperties extends org.apache.avro.specific.SpecificRecordBase implements Serializable

serialVersionUID:

-6929265395822865701L

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package com.linkedin.venice.utils

Class com.linkedin.venice.utils.BoundedHashMap extends java.util.LinkedHashMap<K,V> implements Serializable

serialVersionUID:

1L

Serialized Fields

maxSize

int maxSize

Class com.linkedin.venice.utils.ByteArray extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

underlying

byte[] underlying

Class com.linkedin.venice.utils.Pair extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

first

F first

Deprecated.

second

S second

Deprecated.

Class com.linkedin.venice.utils.SparseConcurrentList extends java.util.concurrent.CopyOnWriteArrayList<E> implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.utils.SparseConcurrentListWithOffset extends SparseConcurrentList<E> implements Serializable

serialVersionUID:

2L

Serialized Fields

offset

int offset

Class com.linkedin.venice.utils.VeniceProperties extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

props

java.util.Map<java.lang.String,java.lang.String> props

Package com.linkedin.venice.utils.collections

Class com.linkedin.venice.utils.collections.MeasurableLinkedHashMap extends java.util.LinkedHashMap<K,V extends Measurable> implements Serializable

Package com.linkedin.venice.utils.concurrent

Class com.linkedin.venice.utils.concurrent.VeniceConcurrentHashMap extends java.util.concurrent.ConcurrentHashMap<K,V> implements Serializable

serialVersionUID:

1L

Class com.linkedin.venice.utils.concurrent.VeniceReentrantReadWriteLock extends java.util.concurrent.locks.ReentrantReadWriteLock implements Serializable

serialVersionUID:

1L

Package com.linkedin.venice.writer

Class com.linkedin.venice.writer.VeniceWriter.DefaultLeaderMetadata extends LeaderMetadata implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Throws:

java.io.IOException

Package io.netty.channel

Class io.netty.channel.ChannelException extends java.lang.RuntimeException implements Serializable

serialVersionUID:

2908618315971075004L

Class io.netty.channel.ChannelPipelineException extends io.netty.channel.ChannelException implements Serializable

serialVersionUID:

3379174210419885980L

Class io.netty.channel.ConnectTimeoutException extends java.net.ConnectException implements Serializable

serialVersionUID:

2317065249988317463L

Class io.netty.channel.DefaultChannelId extends java.lang.Object implements Serializable

serialVersionUID:

3884076183504074063L

Serialized Fields

data

byte[] data

hashCode

int hashCode

Class io.netty.channel.EventLoopException extends io.netty.channel.ChannelException implements Serializable

serialVersionUID:

-8969100344583703616L

Package io.netty.handler.codec.http2

Class io.netty.handler.codec.http2.Http2Exception extends java.lang.Exception implements Serializable

serialVersionUID:

-6941186345430164209L

Serialized Fields

error

io.netty.handler.codec.http2.Http2Error error

shutdownHint

io.netty.handler.codec.http2.Http2Exception.ShutdownHint shutdownHint

Class io.netty.handler.codec.http2.Http2Exception.ClosedStreamCreationException extends io.netty.handler.codec.http2.Http2Exception implements Serializable

serialVersionUID:

-6746542974372246206L

Class io.netty.handler.codec.http2.Http2Exception.CompositeStreamException extends io.netty.handler.codec.http2.Http2Exception implements Serializable

serialVersionUID:

7091134858213711015L

Serialized Fields

exceptions

java.util.List<io.netty.handler.codec.http2.Http2Exception.StreamException> exceptions

Class io.netty.handler.codec.http2.Http2Exception.HeaderListSizeException extends io.netty.handler.codec.http2.Http2Exception.StreamException implements Serializable

serialVersionUID:

-8807603212183882637L

Serialized Fields

decode

boolean decode

Class io.netty.handler.codec.http2.Http2Exception.StreamException extends io.netty.handler.codec.http2.Http2Exception implements Serializable

serialVersionUID:

602472544416984384L

Serialized Fields

streamId

int streamId

Class io.netty.handler.codec.http2.Http2FrameStreamException extends java.lang.Exception implements Serializable

serialVersionUID:

-4407186173493887044L

Serialized Fields

error

io.netty.handler.codec.http2.Http2Error error

stream

io.netty.handler.codec.http2.Http2FrameStream stream

Class io.netty.handler.codec.http2.Http2NoMoreStreamIdsException extends io.netty.handler.codec.http2.Http2Exception implements Serializable

serialVersionUID:

-7756236161274851110L

Class io.netty.handler.codec.http2.StreamBufferingEncoder.Http2ChannelClosedException extends io.netty.handler.codec.http2.Http2Exception implements Serializable

serialVersionUID:

4768543442094476971L

Class io.netty.handler.codec.http2.StreamBufferingEncoder.Http2GoAwayException extends io.netty.handler.codec.http2.Http2Exception implements Serializable

serialVersionUID:

1326785622777291198L

Serialized Fields

debugData

byte[] debugData

errorCode

long errorCode

lastStreamId

int lastStreamId

Package io.netty.handler.timeout

Class io.netty.handler.timeout.ReadTimeoutException extends io.netty.handler.timeout.TimeoutException implements Serializable

serialVersionUID:

169287984113283421L

Class io.netty.handler.timeout.TimeoutException extends io.netty.channel.ChannelException implements Serializable

serialVersionUID:

4673641882869672533L

Class io.netty.handler.timeout.WriteTimeoutException extends io.netty.handler.timeout.TimeoutException implements Serializable

serialVersionUID:

-144786655770296065L

Package org.apache.avro.specific

Class org.apache.avro.specific.SpecificExceptionBase extends org.apache.avro.AvroRemoteException implements Serializable

Serialization Methods

readExternal

public abstract void readExternal(java.io.ObjectInput arg0)
                           throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public abstract void writeExternal(java.io.ObjectOutput arg0)
                            throws java.io.IOException

Throws:

java.io.IOException

Class org.apache.avro.specific.SpecificFixed extends java.lang.Object implements Serializable

Serialization Methods

readExternal

public abstract void readExternal(java.io.ObjectInput arg0)
                           throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public abstract void writeExternal(java.io.ObjectOutput arg0)
                            throws java.io.IOException

Throws:

java.io.IOException

Class org.apache.avro.specific.SpecificRecordBase extends java.lang.Object implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput arg0)
                  throws java.io.IOException

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput arg0)
                   throws java.io.IOException

Throws:

java.io.IOException