public Tuple exec()

in src/main/java/org/apache/datasketches/pig/quantiles/DataToDoublesSketch.java [138:157]

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

  public Tuple exec(final Tuple inputTuple) throws IOException {
    //The exec is a stateless function. It operates on the input and returns a result.
    if ((inputTuple != null) && (inputTuple.size() > 0)) {
      final DoublesUnion union = this.unionBuilder_.build();
      final DataBag bag = (DataBag) inputTuple.get(0);
      for (final Tuple innerTuple: bag) {
        final Object value = innerTuple.get(0);
        if (value != null) {
          union.update((Double) value);
        }
      }
      final DoublesSketch resultSketch = union.getResultAndReset();
      if (resultSketch != null) {
        return tupleFactory_.newTuple(new DataByteArray(resultSketch.toByteArray(true)));
      }
    }
    // return empty sketch
    return tupleFactory_.newTuple(
        new DataByteArray(this.unionBuilder_.build().getResult().toByteArray(true)));
  }