public void accumulate()

in src/main/java/org/apache/datasketches/pig/sampling/ReservoirSampling.java [90:104]

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

  public void accumulate(final Tuple inputTuple) throws IOException {
    if ((inputTuple == null) || (inputTuple.size() < 1) || inputTuple.isNull(0)) {
      return;
    }

    final DataBag samples = (DataBag) inputTuple.get(0);

    if (this.reservoir_ == null) {
      this.reservoir_ = ReservoirItemsSketch.newInstance(this.targetK_);
    }

    for (Tuple t : samples) {
      this.reservoir_.update(t);
    }
  }