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> PType<Tuple3.Collect<V1,V2,V3>> |
Tuple3.Collect.derived(PType<V1> first,
PType<V2> second,
PType<V3> third) |
Modifier and Type | Method and Description |
---|---|
static <K,V1,V2,V3> |
Cogroup.cogroup(int numReducers,
PTable<K,V1> first,
PTable<K,V2> second,
PTable<K,V3> third)
Co-groups the three
PTable arguments with a user-specified degree of parallelism (a.k.a, number of
reducers.) |
static <K,V1,V2,V3> |
Cogroup.cogroup(PTable<K,V1> first,
PTable<K,V2> second,
PTable<K,V3> third)
Co-groups the three
PTable arguments. |
Copyright © 2016 The Apache Software Foundation. All rights reserved.