in src/main/java/org/apache/datasketches/hive/tuple/UnionSketchUDAF.java [118:129]
public void iterate(final AggregationBuffer buf, final Object[] data)
throws HiveException {
if (data[0] == null) { return; }
@SuppressWarnings("unchecked")
final UnionState<S> state = (UnionState<S>) buf;
if (!state.isInitialized()) {
initializeState(state, data);
}
final byte[] serializedSketch = (byte[]) this.sketchInspector_.getPrimitiveJavaObject(data[0]);
if (serializedSketch == null) { return; }
state.update(Sketches.heapifySketch(Memory.wrap(serializedSketch), getSummaryDeserializer()));
}