/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ #ifndef THETA_UNION_HPP_ #define THETA_UNION_HPP_ #include "serde.hpp" #include "theta_sketch.hpp" #include "theta_union_base.hpp" namespace datasketches { // forward declaration template class theta_union_alloc; // alias with default allocator for convenience using theta_union = theta_union_alloc>; /** * Theta Union. * Computes union of Theta sketches. There is no constructor. Use builder instead. */ template> class theta_union_alloc { public: using Entry = uint64_t; using ExtractKey = trivial_extract_key; using Sketch = theta_sketch_alloc; using CompactSketch = compact_theta_sketch_alloc; using resize_factor = theta_constants::resize_factor; // there is no payload in Theta sketch entry struct nop_policy { void operator()(uint64_t internal_entry, uint64_t incoming_entry) const { unused(internal_entry); unused(incoming_entry); } }; using State = theta_union_base; // No constructor here. Use builder instead. class builder; /** * Update the union with a given sketch * @param sketch to update the union with */ template void update(FwdSketch&& sketch); /** * Produces a copy of the current state of the union as a compact sketch. * @param ordered optional flag to specify if an ordered sketch should be produced * @return the result of the union */ CompactSketch get_result(bool ordered = true) const; /// Reset the union to the initial empty state void reset(); private: State state_; // for builder theta_union_alloc(uint8_t lg_cur_size, uint8_t lg_nom_size, resize_factor rf, float p, uint64_t theta, uint64_t seed, const Allocator& allocator); }; /// Theta union builder template class theta_union_alloc::builder: public theta_base_builder { public: builder(const A& allocator = A()); /** * Create an instance of the union with predefined parameters. * @return an instance of the union */ theta_union_alloc build() const; }; } /* namespace datasketches */ #include "theta_union_impl.hpp" #endif