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<java.lang.String> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField)
UpdateResultStatus	handleModifyList(long modifyTimestamp, CollectionRmdTimestamp<java.lang.Object> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField, java.util.List<java.lang.Object> toAddElements, java.util.List<java.lang.Object> toRemoveElements)
UpdateResultStatus	handleModifyMap(long modifyTimestamp, CollectionRmdTimestamp<java.lang.String> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField, java.util.Map<java.lang.String,java.lang.Object> newEntries, java.util.List<java.lang.String> toRemoveKeys)
UpdateResultStatus	handlePutList(long putTimestamp, int coloID, java.util.List<java.lang.Object> newFieldValue, CollectionRmdTimestamp<java.lang.Object> collectionFieldRmd, org.apache.avro.generic.GenericRecord currValueRecord, org.apache.avro.Schema.Field currValueRecordField)
UpdateResultStatus	handlePutMap(long putTimestamp, int coloID, IndexedHashMap<java.lang.String,java.lang.Object> newFieldValue, CollectionRmdTimestamp<java.lang.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 Detail

SortBasedCollectionFieldOpHandler

public SortBasedCollectionFieldOpHandler(AvroCollectionElementComparator elementComparator)

Method Detail

handlePutList

public UpdateResultStatus handlePutList(long putTimestamp,
                                        int coloID,
                                        java.util.List<java.lang.Object> newFieldValue,
                                        CollectionRmdTimestamp<java.lang.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<java.lang.String,java.lang.Object> newFieldValue,
                                       CollectionRmdTimestamp<java.lang.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<java.lang.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<java.lang.Object> collectionFieldRmd,
                                           org.apache.avro.generic.GenericRecord currValueRecord,
                                           org.apache.avro.Schema.Field currValueRecordField,
                                           java.util.List<java.lang.Object> toAddElements,
                                           java.util.List<java.lang.Object> toRemoveElements)

Specified by:

handleModifyList in class CollectionFieldOperationHandler

handleModifyMap

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

Specified by:

handleModifyMap in class CollectionFieldOperationHandler