Package | Description |
---|---|
org.apache.crunch.lib.join |
Inner and outer joins on collections.
|
Constructor and Description |
---|
ShardedJoinStrategy(ShardedJoinStrategy.ShardingStrategy<K> shardingStrategy)
Instantiate with a custom sharding strategy.
|
ShardedJoinStrategy(ShardedJoinStrategy.ShardingStrategy<K> shardingStrategy,
int numReducers)
Instantiate with a custom sharding strategy and a specified number of reducers.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.