public void iterate()

in src/main/java/org/apache/datasketches/hive/theta/IntersectSketchUDAF.java [122:136]

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

    public void iterate(final AggregationBuffer buf,
        final Object[] data) throws HiveException {
      if (data[0] == null) { return; }
      final IntersectionState state = (IntersectionState) buf;
      if (!state.isInitialized()) {
        long seed = DEFAULT_UPDATE_SEED;
        if (this.seedObjectInspector != null) {
          seed = PrimitiveObjectInspectorUtils.getLong(data[1], this.seedObjectInspector);
        }
        state.init(seed);
      }
      final byte[] serializedSketch = (byte[]) this.inputObjectInspector.getPrimitiveJavaObject(data[0]);
      if (serializedSketch == null) { return; }
      state.update(Memory.wrap(serializedSketch));
    }