Package | Description |
---|---|
org.apache.crunch |
Client-facing API and core abstractions.
|
org.apache.crunch.lib |
Joining, sorting, aggregating, and other commonly used functionality.
|
Modifier and Type | Method and Description |
---|---|
static <V1,V2,V3,V4> |
Tuple4.Collect.derived(PType<V1> first,
PType<V2> second,
PType<V3> third,
PType<V4> fourth) |
Modifier and Type | Method and Description |
---|---|
static <K,V1,V2,V3,V4> |
Cogroup.cogroup(int numReducers,
PTable<K,V1> first,
PTable<K,V2> second,
PTable<K,V3> third,
PTable<K,V4> fourth)
Co-groups the three
PTable arguments with a user-specified degree of parallelism (a.k.a, number of
reducers.) |
static <K,V1,V2,V3,V4> |
Cogroup.cogroup(PTable<K,V1> first,
PTable<K,V2> second,
PTable<K,V3> third,
PTable<K,V4> fourth)
Co-groups the three
PTable arguments. |
Copyright © 2016 The Apache Software Foundation. All rights reserved.