private static void updateUnion()

in src/main/java/org/apache/datasketches/pig/theta/Union.java [296:318]

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

  private static void updateUnion(final DataBag bag, final org.apache.datasketches.theta.Union union) {
    // 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);
      if (type == null) {
        continue;
      }
      // add only the first field of the innerTuple to the union
      if (type == DataType.BYTEARRAY) {
        final DataByteArray dba = (DataByteArray) f0;
        if (dba.size() > 0) {
          union.union(Memory.wrap(dba.get()));
        }
      } else {
        throw new IllegalArgumentException("Field type was not DataType.BYTEARRAY: " + type);
      }
    }
  }