public void merge()

in src/main/java/org/apache/datasketches/hive/tuple/SketchEvaluator.java [85:99]

• 15 lines of code
• 3 McCabe index (conditional complexity)

  public void merge(final @SuppressWarnings("deprecation") AggregationBuffer buf, final Object data)
      throws HiveException {
    if (data == null) { return; }
    @SuppressWarnings("unchecked")
    final UnionState<S> state = (UnionState<S>) buf;
    if (!state.isInitialized()) {
      initializeState(state, data);
    }
    final BytesWritable serializedSketch =
        (BytesWritable) this.intermediateInspector_.getStructFieldData(
            data, this.intermediateInspector_.getStructFieldRef(SKETCH_FIELD));
    state.update(Sketches.heapifySketch(
        BytesWritableHelper.wrapAsMemory(serializedSketch),
        getSummaryDeserializer()));
  }