Package com.linkedin.davinci

Class VersionBackend

java.lang.Object

com.linkedin.davinci.VersionBackend

public class VersionBackend
extends 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, ByteBuffer reusableRawValue, org.apache.avro.generic.GenericRecord reusableValueRecord, Map<String,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, Map<String,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, ByteBuffer reusableRawValue, V reusableValue)
protected static void	sendOutHeartbeat(DaVinciBackend backend, Version version)
String	toString()
void	updatePartitionStatus(int partition, ExecutionStatus status, Optional<String> incrementalPushVersion)

Methods inherited from class java.lang.Object

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

Method Details

toString

public String toString()

Overrides:

toString in class 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,
 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,
 ByteBuffer reusableRawValue,
 org.apache.avro.generic.GenericRecord reusableValueRecord,
 Map<String,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,
 Map<String,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,
 Optional<String> incrementalPushVersion)