public void accumulate()

in src/main/java/org/apache/datasketches/pig/cpc/DataToSketch.java [148:160]

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

  public void accumulate(final Tuple inputTuple) throws IOException {
    if (this.isFirstCall_) {
      Logger.getLogger(getClass()).info("Accumulator was used");
      this.isFirstCall_ = false;
    }
    if (inputTuple == null || inputTuple.size() == 0) { return; }
    final DataBag bag = (DataBag) inputTuple.get(0);
    if (bag == null) { return; }
    if (this.accumSketch_ == null) {
      this.accumSketch_ = new CpcSketch(this.lgK_);
    }
    updateSketch(bag, this.accumSketch_);
  }