List of tableOf() Examples

            Pair<Pair<K1, U>, Pair<K2, V>> valuePair = input.second();
            return Pair.of(Pair.of(valuePair.first().first(), valuePair.second().first()),
                Pair.of(valuePair.first().second(), valuePair.second().second()));
          }
        },
        ctf.tableOf(ctf.pairs(left.getKeyType(), right.getKeyType()),
            ctf.pairs(left.getValueType(), right.getValueType())));
  }


  /**
   * Performs a full cross join on the specified {@link PCollection}s (using the

Examples of org.apache.crunch.types.PTypeFamily.tableOf()

      throw new Error();


    PTable<Pair<Integer, Integer>, U> leftCross = left.parallelDo(new GFCross<U>(0, parallelism),
        ltf.tableOf(ltf.pairs(ltf.ints(), ltf.ints()), left.getPType()));
    PTable<Pair<Integer, Integer>, V> rightCross = right.parallelDo(new GFCross<V>(1, parallelism),
        rtf.tableOf(rtf.pairs(rtf.ints(), rtf.ints()), right.getPType()));


    PTable<Pair<Integer, Integer>, Pair<U, V>> cg = leftCross.join(rightCross);


    PTypeFamily ctf = cg.getTypeFamily();

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.

Examples of tableOf()

Examples of org.apache.crunch.types.PTypeFamily.tableOf()

Examples of org.apache.crunch.types.PTypeFamily.tableOf()