edu.umn.cs.spatialHadoop.operations

Class RangeQuery

java.lang.Object

edu.umn.cs.spatialHadoop.operations.RangeQuery

public class RangeQuery
extends java.lang.Object

Performs a range query over a spatial file.

Author:

Ahmed Eldawy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RangeQuery.RangeQueryMap The map function used for range query

Constructor Summary

Constructors

Constructor and Description
RangeQuery()

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
static <S extends Shape> long	rangeQueryLocal(Path inPath, Shape queryRange, S shape, OperationsParams params, ResultCollector<S> output) Runs a range query on the local machine (no MapReduce) and the output is streamed to the provided result collector.
static Job	rangeQueryMapReduce(Path inFile, Path outFile, OperationsParams params)

Methods inherited from class java.lang.Object

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

Constructor Detail

RangeQuery

public RangeQuery()

Method Detail

rangeQueryMapReduce

public static Job rangeQueryMapReduce(Path inFile,
                      Path outFile,
                      OperationsParams params)
                               throws java.io.IOException,
                                      java.lang.ClassNotFoundException,
                                      java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

java.lang.InterruptedException

rangeQueryLocal

public static <S extends Shape> long rangeQueryLocal(Path inPath,
                                     Shape queryRange,
                                     S shape,
                                     OperationsParams params,
                                     ResultCollector<S> output)
                            throws java.io.IOException,
                                   java.lang.InterruptedException

Runs a range query on the local machine (no MapReduce) and the output is streamed to the provided result collector. The query might run in parallel which makes it necessary to design the result collector to accept parallel calls to the method ResultCollector.collect(Object). You can use ResultCollectorSynchronizer to synchronize calls to your ResultCollector if you cannot design yours to be thread safe.

Parameters:

inFile -

params -

output -

Returns:

Throws:

java.io.IOException

java.lang.InterruptedException

main

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

Throws:

java.io.IOException

java.lang.ClassNotFoundException

java.lang.InterruptedException