Searched refs:StoreUpdate (Results 1 – 12 of 12) sorted by relevance
49 struct StoreUpdate { struct50 StoreUpdate();51 ~StoreUpdate();52 StoreUpdate(const StoreUpdate&);53 StoreUpdate(StoreUpdate&&);54 StoreUpdate& operator=(const StoreUpdate&); argument55 StoreUpdate& operator=(StoreUpdate&&); argument71 virtual void OnStoreChange(const StoreUpdate& update) = 0; argument
32 StreamModel::StoreUpdate::StoreUpdate() = default;33 StreamModel::StoreUpdate::~StoreUpdate() = default;34 StreamModel::StoreUpdate::StoreUpdate(const StoreUpdate&) = default;35 StreamModel::StoreUpdate& StreamModel::StoreUpdate::operator=(36 const StoreUpdate&) = default;37 StreamModel::StoreUpdate::StoreUpdate(StoreUpdate&&) = default;38 StreamModel::StoreUpdate& StreamModel::StoreUpdate::operator=(StoreUpdate&&) =148 StoreUpdate store_update; in ExecuteOperations()
22 using StoreUpdate = StreamModel::StoreUpdate; typedef62 void OnStoreChange(const StoreUpdate& records) override { update_ = records; } in OnStoreChange()64 const base::Optional<StoreUpdate>& GetUpdate() const { return update_; } in GetUpdate()69 base::Optional<StoreUpdate> update_;306 StoreUpdate store_update = *store_observer.GetUpdate(); in TEST()
111 void OnStoreChange(const StreamModel::StoreUpdate& update) override;
352 void FeedStream::OnStoreChange(const StreamModel::StoreUpdate& update) { in OnStoreChange()
22 using StoreUpdate = StreamModel::StoreUpdate; typedef37 StoreUpdate::StoreUpdate() = default;38 StoreUpdate::~StoreUpdate() = default;39 StoreUpdate::StoreUpdate(StoreUpdate&&) = default;40 StoreUpdate& StoreUpdate::operator=(StoreUpdate&&) = default;110 StoreUpdate store_update; in Update()171 StoreUpdate store_update; in ExecuteOperations()
51 struct StoreUpdate { struct52 StoreUpdate();53 ~StoreUpdate();54 StoreUpdate(StoreUpdate&&);55 StoreUpdate& operator=(StoreUpdate&&); argument77 virtual void OnStoreChange(StoreUpdate update) = 0; argument
23 using StoreUpdate = StreamModel::StoreUpdate; typedef62 void OnStoreChange(StoreUpdate records) override { in OnStoreChange()66 const base::Optional<StoreUpdate>& GetUpdate() const { return update_; } in GetUpdate()71 base::Optional<StoreUpdate> update_;308 const StoreUpdate& store_update = *store_observer.GetUpdate(); in TEST()
189 void OnStoreChange(StreamModel::StoreUpdate update) override;
544 void FeedStream::OnStoreChange(StreamModel::StoreUpdate update) { in OnStoreChange()
79 def updates(): Iterator[StoreUpdate]103 sealed trait StoreUpdate { trait108 case class ValueAdded(key: UnsafeRow, value: UnsafeRow) extends StoreUpdate110 case class ValueUpdated(key: UnsafeRow, value: UnsafeRow) extends StoreUpdate112 case class ValueRemoved(key: UnsafeRow, value: UnsafeRow) extends StoreUpdate
91 private val allUpdates = new java.util.HashMap[UnsafeRow, StoreUpdate]()195 override def updates(): Iterator[StoreUpdate] = {325 private def writeToDeltaFile(output: DataOutputStream, update: StoreUpdate): Unit = {