Package | Description |
---|---|
org.apache.crunch.lib |
Joining, sorting, aggregating, and other commonly used functionality.
|
Modifier and Type | Method and Description |
---|---|
Sort.Order |
Sort.ColumnOrder.order() |
static Sort.Order |
Sort.Order.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Sort.Order[] |
Sort.Order.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static Sort.ColumnOrder |
Sort.ColumnOrder.by(int column,
Sort.Order order) |
static <T> PCollection<T> |
Sort.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 <T> PCollection<T> |
Sort.sort(PCollection<T> collection,
Sort.Order order)
Sorts the
PCollection using the natural order of its elements with the given Order . |
static <K,V> PTable<K,V> |
Sort.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 <K,V> PTable<K,V> |
Sort.sort(PTable<K,V> table,
Sort.Order key)
Sorts the
PTable using the natural ordering of its keys with the given Order . |
Constructor and Description |
---|
ColumnOrder(int column,
Sort.Order order) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.