edu.umn.cs.spatialHadoop.operations

Class Indexer

java.lang.Object

edu.umn.cs.spatialHadoop.operations.Indexer

public class Indexer
extends java.lang.Object

Author:

Ahmed Eldawy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Indexer.IndexerOutputCommitter Output committer that concatenates all master files into one master file.
static class	Indexer.IndexMethods The map and reduce functions for the repartition

Constructor Summary

Constructors

Constructor and Description
Indexer()

Method Summary

Methods

Modifier and Type	Method and Description
static Partitioner	createPartitioner(Path[] ins, Path out, Configuration job, java.lang.String partitionerName) Create a partitioner for a particular job
static Partitioner	createPartitioner(Path in, Path out, Configuration job, java.lang.String partitionerName)
static RunningJob	index(Path inPath, Path outPath, OperationsParams params)
static void	main(java.lang.String[] args) Entry point to the indexing operation.
protected static void	printUsage()

Methods inherited from class java.lang.Object

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

Constructor Detail

Indexer

public Indexer()

Method Detail

createPartitioner

public static Partitioner createPartitioner(Path in,
                            Path out,
                            Configuration job,
                            java.lang.String partitionerName)
                                     throws java.io.IOException

Throws:

java.io.IOException

createPartitioner

public static Partitioner createPartitioner(Path[] ins,
                            Path out,
                            Configuration job,
                            java.lang.String partitionerName)
                                     throws java.io.IOException

Create a partitioner for a particular job

Parameters:

in -

out -

job -

partitionerName -

Returns:

Throws:

java.io.IOException

index

public static RunningJob index(Path inPath,
               Path outPath,
               OperationsParams params)
                        throws java.io.IOException,
                               java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

printUsage

protected static void printUsage()

main

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

Entry point to the indexing operation.

Parameters:

args -

Throws:

java.lang.Exception