Package com.linkedin.davinci

Class VersionBackend

java.lang.Object

com.linkedin.davinci.VersionBackend

public class VersionBackend
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	compute(int userPartition, byte[] keyBytes, AbstractAvroChunkingAdapter<org.apache.avro.generic.GenericRecord> chunkingAdaptor, AvroStoreDeserializerCache<org.apache.avro.generic.GenericRecord> storeDeserializerCache, int readerSchemaId, org.apache.avro.io.BinaryDecoder binaryDecoder, java.nio.ByteBuffer reusableRawValue, org.apache.avro.generic.GenericRecord reusableValueRecord, java.util.Map<java.lang.String,java.lang.Object> sharedContext, ComputeRequestWrapper computeRequestWrapper, org.apache.avro.Schema computeResultSchema)
void	computeWithKeyPrefixFilter(byte[] keyPrefix, int partition, StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback, ComputeRequestWrapper computeRequestWrapper, AbstractAvroChunkingAdapter<org.apache.avro.generic.GenericRecord> chunkingAdaptor, RecordDeserializer<org.apache.avro.generic.GenericRecord> keyRecordDeserializer, org.apache.avro.generic.GenericRecord reusableValueRecord, org.apache.avro.io.BinaryDecoder reusableBinaryDecoder, java.util.Map<java.lang.String,java.lang.Object> sharedContext, org.apache.avro.Schema computeResultSchema)
int	getPartition(byte[] keyBytes)
int	getPartitionCount()
int	getSupersetOrLatestValueSchemaId()
Version	getVersion()
boolean	isPartitionReadyToServe(int partition)
boolean	isPartitionSubscribed(int partition)
<V> V	read(int userPartition, byte[] keyBytes, AbstractAvroChunkingAdapter<V> chunkingAdaptor, StoreDeserializerCache<V> storeDeserializerCache, int readerSchemaId, org.apache.avro.io.BinaryDecoder binaryDecoder, java.nio.ByteBuffer reusableRawValue, V reusableValue)
protected static void	sendOutHeartbeat(DaVinciBackend backend, Version version)
java.lang.String	toString()
void	updatePartitionStatus(int partition, ExecutionStatus status, java.util.Optional<java.lang.String> incrementalPushVersion)

Methods inherited from class java.lang.Object

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

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getVersion

public Version getVersion()

sendOutHeartbeat

protected static void sendOutHeartbeat(DaVinciBackend backend,
                                       Version version)

read

public <V> V read(int userPartition,
                  byte[] keyBytes,
                  AbstractAvroChunkingAdapter<V> chunkingAdaptor,
                  StoreDeserializerCache<V> storeDeserializerCache,
                  int readerSchemaId,
                  org.apache.avro.io.BinaryDecoder binaryDecoder,
                  java.nio.ByteBuffer reusableRawValue,
                  V reusableValue)

compute

public org.apache.avro.generic.GenericRecord compute(int userPartition,
                                                     byte[] keyBytes,
                                                     AbstractAvroChunkingAdapter<org.apache.avro.generic.GenericRecord> chunkingAdaptor,
                                                     AvroStoreDeserializerCache<org.apache.avro.generic.GenericRecord> storeDeserializerCache,
                                                     int readerSchemaId,
                                                     org.apache.avro.io.BinaryDecoder binaryDecoder,
                                                     java.nio.ByteBuffer reusableRawValue,
                                                     org.apache.avro.generic.GenericRecord reusableValueRecord,
                                                     java.util.Map<java.lang.String,java.lang.Object> sharedContext,
                                                     ComputeRequestWrapper computeRequestWrapper,
                                                     org.apache.avro.Schema computeResultSchema)

computeWithKeyPrefixFilter

public void computeWithKeyPrefixFilter(byte[] keyPrefix,
                                       int partition,
                                       StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback,
                                       ComputeRequestWrapper computeRequestWrapper,
                                       AbstractAvroChunkingAdapter<org.apache.avro.generic.GenericRecord> chunkingAdaptor,
                                       RecordDeserializer<org.apache.avro.generic.GenericRecord> keyRecordDeserializer,
                                       org.apache.avro.generic.GenericRecord reusableValueRecord,
                                       org.apache.avro.io.BinaryDecoder reusableBinaryDecoder,
                                       java.util.Map<java.lang.String,java.lang.Object> sharedContext,
                                       org.apache.avro.Schema computeResultSchema)

getPartitionCount

public int getPartitionCount()

getPartition

public int getPartition(byte[] keyBytes)

isPartitionSubscribed

public boolean isPartitionSubscribed(int partition)

isPartitionReadyToServe

public boolean isPartitionReadyToServe(int partition)

getSupersetOrLatestValueSchemaId

public int getSupersetOrLatestValueSchemaId()

updatePartitionStatus

public void updatePartitionStatus(int partition,
                                  ExecutionStatus status,
                                  java.util.Optional<java.lang.String> incrementalPushVersion)