Package com.linkedin.venice.writer
package com.linkedin.venice.writer
-
ClassDescriptionAbstractVeniceWriter<K,
V, U> A base class which users ofVeniceWritercan leverage in order to make unit tests easier.TheVeniceWriter, upon detecting an instance of this class being passed to it, will always callChunkAwareCallback.setChunkingInfo(byte[], ByteBuffer[], ChunkedValueManifest, ByteBuffer[], ChunkedValueManifest, ChunkedValueManifest, ChunkedValueManifest)whenever processing aMessageType.PUT, whether it is chunked or not.This class contains both chunked results and manifest for a specific payload.Compose a CompletableFuture and Callback together to be aCompletableFutureCallbacktype.CompositeVeniceWriter<K,V, U> The composite writer contains a main writer and multiple child writers.This is a simple container class to hold replication metadata related fields together to be passed on to the Delete api in VeniceWriterVeniceWriter#delete(Object, Callback, LeaderMetadataWrapper, long, Optional).Completion state of the leader partition.This is a simple container class to hold Leader metadata related fields together to be passed on to the Put and Delete api in VeniceWriter Caller should construct an instance of this object by properly filling up all the fields of this object.This is a simple container class to hold replication metadata related fields together to be passed on to the Put api in VeniceWriterVeniceWriter.put(Object, Object, int, Callback, LeaderMetadataWrapper, long, PutMetadata).VeniceWriter<K,V, U> Class which acts as the primary writer API.An interface which enables the key to contain parts of the within it, which is useful for control messages and chunked values.Factory used to createVeniceWriter.VeniceWriterOptions is used to pass arguments to VeniceWriter constructor.This class is a helper class that contains writer side chunking logics.