|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.crunch.lib.Sort
public class Sort
Utilities for sorting PCollection
instances.
Nested Class Summary | |
---|---|
static class |
Sort.ColumnOrder
To sort by column 2 ascending then column 1 descending, you would use:
sortPairs(coll, by(2, ASCENDING), by(1, DESCENDING))
Column numbering is 1-based. |
static class |
Sort.Order
For signaling the order in which a sort should be done. |
Constructor Summary | |
---|---|
Sort()
|
Method Summary | ||
---|---|---|
static
|
sort(PCollection<T> collection)
Sorts the PCollection using the natural ordering of its elements in ascending order. |
|
static
|
sort(PCollection<T> collection,
int numReducers,
Sort.Order order)
Sorts the PCollection using the natural ordering of its elements in
the order specified using the given number of reducers. |
|
static
|
sort(PCollection<T> collection,
Sort.Order order)
Sorts the PCollection using the natural order of its elements with the given Order . |
|
static
|
sort(PTable<K,V> table)
Sorts the PTable using the natural ordering of its keys in ascending order. |
|
static
|
sort(PTable<K,V> table,
int numReducers,
Sort.Order key)
Sorts the PTable using the natural ordering of its keys in the
order specified with a client-specified number of reducers. |
|
static
|
sort(PTable<K,V> table,
Sort.Order key)
Sorts the PTable using the natural ordering of its keys with the given Order . |
|
static
|
sortPairs(PCollection<Pair<U,V>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the PCollection of Pair s using the specified column
ordering. |
|
static
|
sortQuads(PCollection<Tuple4<V1,V2,V3,V4>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the PCollection of Tuple4 s using the specified column
ordering. |
|
static
|
sortTriples(PCollection<Tuple3<V1,V2,V3>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the PCollection of Tuple3 s using the specified column
ordering. |
|
static
|
sortTuples(PCollection<T> collection,
int numReducers,
Sort.ColumnOrder... columnOrders)
Sorts the PCollection of TupleN s using the specified column
ordering and a client-specified number of reducers. |
|
static
|
sortTuples(PCollection<T> collection,
Sort.ColumnOrder... columnOrders)
Sorts the PCollection of tuples using the specified column ordering. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Sort()
Method Detail |
---|
public static <T> PCollection<T> sort(PCollection<T> collection)
PCollection
using the natural ordering of its elements in ascending order.
PCollection
representing the sorted collection.public static <T> PCollection<T> sort(PCollection<T> collection, Sort.Order order)
PCollection
using the natural order of its elements with the given Order
.
PCollection
representing the sorted collection.public static <T> PCollection<T> sort(PCollection<T> collection, int numReducers, Sort.Order order)
PCollection
using the natural ordering of its elements in
the order specified using the given number of reducers.
PCollection
representing the sorted collection.public static <K,V> PTable<K,V> sort(PTable<K,V> table)
PTable
using the natural ordering of its keys in ascending order.
PTable
representing the sorted table.public static <K,V> PTable<K,V> sort(PTable<K,V> table, Sort.Order key)
PTable
using the natural ordering of its keys with the given Order
.
PTable
representing the sorted table.public static <K,V> PTable<K,V> sort(PTable<K,V> table, int numReducers, Sort.Order key)
PTable
using the natural ordering of its keys in the
order specified with a client-specified number of reducers.
PTable
representing the sorted collection.public static <U,V> PCollection<Pair<U,V>> sortPairs(PCollection<Pair<U,V>> collection, Sort.ColumnOrder... columnOrders)
PCollection
of Pair
s using the specified column
ordering.
PCollection
representing the sorted collection.public static <V1,V2,V3> PCollection<Tuple3<V1,V2,V3>> sortTriples(PCollection<Tuple3<V1,V2,V3>> collection, Sort.ColumnOrder... columnOrders)
PCollection
of Tuple3
s using the specified column
ordering.
PCollection
representing the sorted collection.public static <V1,V2,V3,V4> PCollection<Tuple4<V1,V2,V3,V4>> sortQuads(PCollection<Tuple4<V1,V2,V3,V4>> collection, Sort.ColumnOrder... columnOrders)
PCollection
of Tuple4
s using the specified column
ordering.
PCollection
representing the sorted collection.public static <T extends Tuple> PCollection<T> sortTuples(PCollection<T> collection, Sort.ColumnOrder... columnOrders)
PCollection
of tuples using the specified column ordering.
PCollection
representing the sorted collection.public static <T extends Tuple> PCollection<T> sortTuples(PCollection<T> collection, int numReducers, Sort.ColumnOrder... columnOrders)
PCollection
of TupleN
s using the specified column
ordering and a client-specified number of reducers.
PCollection
representing the sorted collection.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |