public void accumulate()

in src/main/java/org/apache/datasketches/pig/quantiles/UnionItemsSketch.java [168:178]

• 11 lines of code
• 6 McCabe index (conditional complexity)

  public void accumulate(final Tuple inputTuple) throws IOException {
    if (inputTuple == null || inputTuple.size() == 0) { return; }
    final DataBag bag = (DataBag) inputTuple.get(0);
    if (bag == null) { return; }
    if (this.accumUnion_ == null) {
      this.accumUnion_ = this.k_ > 0 
          ? ItemsUnion.getInstance(this.k_, this.comparator_) 
          : ItemsUnion.getInstance(this.comparator_);
    }
    updateUnion(bag, this.accumUnion_, this.comparator_, this.serDe_);
  }