private static void updateIntersection()

in src/main/java/org/apache/datasketches/pig/theta/Intersect.java [243:265]

• 20 lines of code
• 4 McCabe index (conditional complexity)

  private static void updateIntersection(final DataBag bag, final Intersection intersection,
      final long seed) {
    //Bag is not empty. process each innerTuple in the bag
    for (Tuple innerTuple : bag) {
      //validate the inner Tuples
      final Object f0 = extractFieldAtIndex(innerTuple, 0);
      if (f0 == null) {
      continue;
    }
      final Byte type = extractTypeAtIndex(innerTuple, 0);
    // add only the first field of the innerTuple to the intersection
    if (type == DataType.BYTEARRAY) {
      final DataByteArray dba = (DataByteArray) f0;
      final Memory srcMem = Memory.wrap(dba.get());
      final Sketch sketch = Sketch.wrap(srcMem, seed);
      intersection.intersect(sketch);
    }
    else {
      throw new IllegalArgumentException(
          "Field type was not DataType.BYTEARRAY: " + type);
      }
    }
  }