pegasus.mapreduce.netray

Class NetRayScatter

java.lang.Object

org.apache.hadoop.conf.Configured

pegasus.mapreduce.netray.NetRayScatter

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class NetRayScatter
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NetRayScatter.MapStage1
static class	NetRayScatter.MapStage2
static class	NetRayScatter.RedStage1
static class	NetRayScatter.RedStage2

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	field_ids
protected org.apache.hadoop.fs.Path	input_path
protected int	is_linear
protected org.apache.hadoop.fs.Path	minmax_path
protected int	nreducer
protected int	orig_nnodes
protected org.apache.hadoop.fs.Path	output_path
protected double	sm1_over_logxmax_m_logxmin
protected double	sm1_over_logymax_m_logymin
protected double	sm1_over_xmax_m_xmin
protected double	sm1_over_ymax_m_ymin
protected int	target_nnodes
protected double	x_max
protected double	x_min
protected double	y_max
protected double	y_min

Constructor Summary

Constructors

Constructor and Description
NetRayScatter()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.mapreduce.Job	configStage1(org.apache.hadoop.fs.Path in_path, org.apache.hadoop.fs.Path out_path)
protected org.apache.hadoop.mapreduce.Job	configStage2()
static void	main(java.lang.String[] args)
protected static int	printUsage()
void	readMinMax(java.lang.String new_path)
int	run(java.lang.String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

input_path

protected org.apache.hadoop.fs.Path input_path

minmax_path

protected org.apache.hadoop.fs.Path minmax_path

output_path

protected org.apache.hadoop.fs.Path output_path

orig_nnodes

protected int orig_nnodes

target_nnodes

protected int target_nnodes

sm1_over_xmax_m_xmin

protected double sm1_over_xmax_m_xmin

sm1_over_ymax_m_ymin

protected double sm1_over_ymax_m_ymin

sm1_over_logxmax_m_logxmin

protected double sm1_over_logxmax_m_logxmin

sm1_over_logymax_m_logymin

protected double sm1_over_logymax_m_logymin

field_ids

protected java.lang.String field_ids

nreducer

protected int nreducer

is_linear

protected int is_linear

x_min

protected double x_min

x_max

protected double x_max

y_min

protected double y_min

y_max

protected double y_max

Constructor Detail

NetRayScatter

public NetRayScatter()

Method Detail

main

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

Throws:

java.lang.Exception

printUsage

protected static int printUsage()

run

public int run(java.lang.String[] args)
        throws java.lang.Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

java.lang.Exception

readMinMax

public void readMinMax(java.lang.String new_path)
                throws java.lang.Exception

Throws:

java.lang.Exception

configStage1

protected org.apache.hadoop.mapreduce.Job configStage1(org.apache.hadoop.fs.Path in_path,
                                                       org.apache.hadoop.fs.Path out_path)
                                                throws java.lang.Exception

Throws:

java.lang.Exception

configStage2

protected org.apache.hadoop.mapreduce.Job configStage2()
                                                throws java.lang.Exception

Throws:

java.lang.Exception