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.RangeFilter A filter function that selects partitions overlapping with a query range.
static class	RangeQuery.RangeQueryMap The map function used for range query
static class	RangeQuery.RangeQueryMapNoDupAvoidance The map function used for range query

Field Summary

Fields

Modifier and Type	Field and Description
static RunningJob	lastRunningJob Reference to the last range query job submitted

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 long	rangeQueryMapReduce(Path inFile, Path outFile, Shape query, OperationsParams params)

Methods inherited from class java.lang.Object

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

Field Detail

lastRunningJob

public static RunningJob lastRunningJob

Reference to the last range query job submitted

Constructor Detail

RangeQuery

public RangeQuery()

Method Detail

rangeQueryMapReduce

public static long rangeQueryMapReduce(Path inFile,
                       Path outFile,
                       Shape query,
                       OperationsParams params)
                                throws java.io.IOException

Throws:

java.io.IOException

rangeQueryLocal

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

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

main

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

Throws:

java.io.IOException