Package com.linkedin.davinci.schema.merge

Class SortBasedCollectionFieldOpHandler

java.lang.Object

com.linkedin.davinci.schema.merge.CollectionFieldOperationHandler

com.linkedin.davinci.schema.merge.SortBasedCollectionFieldOpHandler

@ThreadSafe
public class SortBasedCollectionFieldOpHandler
extends CollectionFieldOperationHandler

Field Summary

Fields inherited from class com.linkedin.davinci.schema.merge.CollectionFieldOperationHandler

avroElementComparator

Constructor Summary

Constructors

Constructor	Description
SortBasedCollectionFieldOpHandler(AvroCollectionElementComparator elementComparator)

Method Summary

Modifier and Type	Method	Description
UpdateResultStatus	handleDeleteList(long deleteTimestamp, int coloID, CollectionRmdTimestamp collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField)
UpdateResultStatus	handleDeleteMap(long deleteTimestamp, int coloID, CollectionRmdTimestamp<String> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField)
UpdateResultStatus	handleModifyList(long modifyTimestamp, CollectionRmdTimestamp<Object> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField, List<Object> toAddElements, List<Object> toRemoveElements)
UpdateResultStatus	handleModifyMap(long modifyTimestamp, CollectionRmdTimestamp<String> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField, Map<String,Object> newEntries, List<String> toRemoveKeys)
UpdateResultStatus	handlePutList(long putTimestamp, int coloID, List<Object> newFieldValue, CollectionRmdTimestamp<Object> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField)
UpdateResultStatus	handlePutMap(long putTimestamp, int coloID, IndexedHashMap<String,Object> newFieldValue, CollectionRmdTimestamp<String> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField)

Methods inherited from class java.lang.Object

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

Constructor Details

SortBasedCollectionFieldOpHandler

public SortBasedCollectionFieldOpHandler(AvroCollectionElementComparator elementComparator)

Method Details

handlePutList

public UpdateResultStatus handlePutList(long putTimestamp,
 int coloID,
 List<Object> newFieldValue,
 CollectionRmdTimestamp<Object> collectionFieldRmd,
 org.apache.avro.generic.GenericRecord currValueRecord,
 org.apache.avro.Schema.Field currValueRecordField)

Specified by:

handlePutList in class CollectionFieldOperationHandler

handlePutMap

public UpdateResultStatus handlePutMap(long putTimestamp,
 int coloID,
 IndexedHashMap<String,Object> newFieldValue,
 CollectionRmdTimestamp<String> collectionFieldRmd,
 org.apache.avro.generic.GenericRecord currValueRecord,
 org.apache.avro.Schema.Field currValueRecordField)

Specified by:

handlePutMap in class CollectionFieldOperationHandler

handleDeleteList

public UpdateResultStatus handleDeleteList(long deleteTimestamp,
 int coloID,
 CollectionRmdTimestamp collectionFieldRmd,
 org.apache.avro.generic.GenericRecord currValueRecord,
 org.apache.avro.Schema.Field currValueRecordField)

Specified by:

handleDeleteList in class CollectionFieldOperationHandler

handleDeleteMap

public UpdateResultStatus handleDeleteMap(long deleteTimestamp,
 int coloID,
 CollectionRmdTimestamp<String> collectionFieldRmd,
 org.apache.avro.generic.GenericRecord currValueRecord,
 org.apache.avro.Schema.Field currValueRecordField)

Specified by:

handleDeleteMap in class CollectionFieldOperationHandler

handleModifyList

public UpdateResultStatus handleModifyList(long modifyTimestamp,
 CollectionRmdTimestamp<Object> collectionFieldRmd,
 org.apache.avro.generic.GenericRecord currValueRecord,
 org.apache.avro.Schema.Field currValueRecordField,
 List<Object> toAddElements,
 List<Object> toRemoveElements)

Specified by:

handleModifyList in class CollectionFieldOperationHandler

handleModifyMap

public UpdateResultStatus handleModifyMap(long modifyTimestamp,
 CollectionRmdTimestamp<String> collectionFieldRmd,
 org.apache.avro.generic.GenericRecord currValueRecord,
 org.apache.avro.Schema.Field currValueRecordField,
 Map<String,Object> newEntries,
 List<String> toRemoveKeys)

Specified by:

handleModifyMap in class CollectionFieldOperationHandler