Package | Description |
---|---|
org.apache.crunch.lib |
Joining, sorting, aggregating, and other commonly used functionality.
|
org.apache.crunch.lib.sort |
Modifier and Type | Method and Description |
---|---|
static Sort.ColumnOrder |
Sort.ColumnOrder.by(int column,
Sort.Order order) |
Modifier and Type | Method and Description |
---|---|
static <U,V> PCollection<Pair<U,V>> |
Sort.sortPairs(PCollection<Pair<U,V>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of Pair s using the specified column
ordering. |
static <V1,V2,V3,V4> |
Sort.sortQuads(PCollection<Tuple4<V1,V2,V3,V4>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of Tuple4 s using the specified column
ordering. |
static <V1,V2,V3> PCollection<Tuple3<V1,V2,V3>> |
Sort.sortTriples(PCollection<Tuple3<V1,V2,V3>> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of Tuple3 s using the specified column
ordering. |
static <T extends Tuple> |
Sort.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 <T extends Tuple> |
Sort.sortTuples(PCollection<T> collection,
Sort.ColumnOrder... columnOrders)
Sorts the
PCollection of tuples using the specified column ordering. |
Modifier and Type | Method and Description |
---|---|
static void |
TupleWritableComparator.configureOrdering(org.apache.hadoop.conf.Configuration conf,
WritableType[] types,
Sort.ColumnOrder[] columnOrders) |
static <S> org.apache.avro.Schema |
SortFns.createOrderedTupleSchema(PType<S> ptype,
Sort.ColumnOrder[] orders)
Constructs an Avro schema for the given
PType<S> that respects the given column
orderings. |
Constructor and Description |
---|
KeyExtraction(PType<V> ptype,
Sort.ColumnOrder[] columnOrder) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.