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)

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)