edu.umn.cs.spatialHadoop.operations

Class SJMR

java.lang.Object

edu.umn.cs.spatialHadoop.operations.SJMR

public class SJMR
extends java.lang.Object

An implementation of Spatial Join MapReduce as described in S. Zhang, J. Han, Z. Liu, K. Wang, and Z. Xu. SJMR: Parallelizing spatial join with MapReduce on clusters. In CLUSTER, pages 1–8, New Orleans, LA, Aug. 2009. The map function partitions data into grid cells and the reduce function makes a plane-sweep over each cell.

Author:

eldawy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SJMR.IndexedText
static class	SJMR.SelfSJMRMap Map function for the self join version of SJMR.
static class	SJMR.SelfSJMRReduce<S extends Shape>
static class	SJMR.SJMRMap The map class maps each object to all cells it overlaps with.
static class	SJMR.SJMRReduce<S extends Shape>

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PartitioiningGridParam

Constructor Summary

Constructors

Constructor and Description
SJMR()

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
static <S extends Shape> long	sjmr(Path[] inFiles, Path userOutputPath, OperationsParams params)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PartitioiningGridParam

public static final java.lang.String PartitioiningGridParam

See Also:

Constant Field Values

Constructor Detail

SJMR

public SJMR()

Method Detail

sjmr

public static <S extends Shape> long sjmr(Path[] inFiles,
                          Path userOutputPath,
                          OperationsParams params)
                 throws java.io.IOException

Throws:

java.io.IOException

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException

Parameters:

args -

Throws:

java.io.IOException