apache-datasketches-sys 0.2.1

Raw cxx bridge to Apache DataSketches C++ (do not use directly; see apache-datasketches)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

#include "cpc_sketch_shim.h"

namespace apache_datasketches_rs {

CpcSketchShim::CpcSketchShim(uint8_t lg_k) : sketch_(lg_k) {}

CpcSketchShim::CpcSketchShim(datasketches::cpc_sketch sketch)
  : sketch_(std::move(sketch)) {}

void CpcSketchShim::update_u64(uint64_t value) { sketch_.update(value); }
void CpcSketchShim::update_i64(int64_t value) { sketch_.update(value); }
void CpcSketchShim::update_u32(uint32_t value) { sketch_.update(value); }
void CpcSketchShim::update_i32(int32_t value) { sketch_.update(value); }
void CpcSketchShim::update_u16(uint16_t value) { sketch_.update(value); }
void CpcSketchShim::update_i16(int16_t value) { sketch_.update(value); }
void CpcSketchShim::update_u8(uint8_t value) { sketch_.update(value); }
void CpcSketchShim::update_i8(int8_t value) { sketch_.update(value); }
void CpcSketchShim::update_f64(double value) { sketch_.update(value); }
void CpcSketchShim::update_f32(float value) { sketch_.update(value); }
void CpcSketchShim::update_str(rust::Str value) {
  sketch_.update(std::string(value));
}
void CpcSketchShim::update_bytes(rust::Slice<const uint8_t> value) {
  sketch_.update(value.data(), value.size());
}

bool CpcSketchShim::is_empty() const { return sketch_.is_empty(); }
double CpcSketchShim::get_estimate() const { return sketch_.get_estimate(); }
double CpcSketchShim::get_lower_bound(uint8_t num_std_dev) const {
  return sketch_.get_lower_bound(num_std_dev);
}
double CpcSketchShim::get_upper_bound(uint8_t num_std_dev) const {
  return sketch_.get_upper_bound(num_std_dev);
}
uint8_t CpcSketchShim::get_lg_k() const { return sketch_.get_lg_k(); }

rust::String CpcSketchShim::to_string_summary() const {
  return rust::String(std::string(sketch_.to_string().c_str()));
}

rust::Vec<uint8_t> CpcSketchShim::serialize() const {
  auto bytes = sketch_.serialize();
  rust::Vec<uint8_t> out;
  out.reserve(bytes.size());
  for (auto b : bytes) out.push_back(b);
  return out;
}

std::unique_ptr<CpcSketchShim> new_cpc_sketch(uint8_t lg_k) {
  return std::make_unique<CpcSketchShim>(lg_k);
}

std::unique_ptr<CpcSketchShim> cpc_sketch_deserialize(rust::Slice<const uint8_t> bytes) {
  return std::make_unique<CpcSketchShim>(
      datasketches::cpc_sketch::deserialize(bytes.data(), bytes.size()));
}

size_t cpc_sketch_max_serialized_size_bytes(uint8_t lg_k) {
  return datasketches::cpc_sketch::get_max_serialized_size_bytes(lg_k);
}

void cpc_init() {
  datasketches::cpc_init<std::allocator<uint8_t>>();
}

} // namespace apache_datasketches_rs