org.apache.giraph.io.hcatalog

Class HCatGiraphRunner

java.lang.Object

org.apache.giraph.io.hcatalog.HCatGiraphRunner

All Implemented Interfaces:

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

public class HCatGiraphRunner
extends Object
implements org.apache.hadoop.util.Tool

Hive Giraph Runner

Field Summary

Fields

Modifier and Type	Field and Description
protected String	dbName dbName
protected String	edgeInputTableFilterExpr edge input table filter
protected String	edgeInputTableName edge input table name
protected boolean	isVerbose is verbose
protected String	outputTableName output table name
protected Map<String,String>	outputTablePartitionValues output table partitions
protected String	vertexInputTableFilterExpr vertex input table filter
protected String	vertexInputTableName vertex input table name
protected int	workers workers

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HCatGiraphRunner(Class<? extends Computation> computationClass, Class<? extends VertexInputFormat> vertexInputFormatClass, Class<? extends EdgeInputFormat> edgeInputFormatClass, Class<? extends VertexOutputFormat> vertexOutputFormatClass) Giraph runner class.

Method Summary

Modifier and Type	Method and Description
protected void	addMoreOptions(org.apache.commons.cli.Options options) Override this method to add more command-line options.
org.apache.hadoop.conf.Configuration	getConf()
protected void	initGiraphJob(GiraphJob job) Override this method to do additional setup with the GiraphJob that will run.
static void	main(String[] args) main method
protected void	processMoreArguments(org.apache.commons.cli.CommandLine cmd) Override this method to process additional command-line arguments.
int	run(String[] args)
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

workers

protected int workers

workers

isVerbose

protected boolean isVerbose

is verbose

outputTablePartitionValues

protected Map<String,String> outputTablePartitionValues

output table partitions

dbName

protected String dbName

dbName

vertexInputTableName

protected String vertexInputTableName

vertex input table name

vertexInputTableFilterExpr

protected String vertexInputTableFilterExpr

vertex input table filter

edgeInputTableName

protected String edgeInputTableName

edge input table name

edgeInputTableFilterExpr

protected String edgeInputTableFilterExpr

edge input table filter

outputTableName

protected String outputTableName

output table name

Constructor Detail

HCatGiraphRunner

protected HCatGiraphRunner(Class<? extends Computation> computationClass,
                           Class<? extends VertexInputFormat> vertexInputFormatClass,
                           Class<? extends EdgeInputFormat> edgeInputFormatClass,
                           Class<? extends VertexOutputFormat> vertexOutputFormatClass)

Giraph runner class.

Parameters:

computationClass - Computation class

vertexInputFormatClass - Vertex input format

edgeInputFormatClass - Edge input format

vertexOutputFormatClass - Output format

Method Detail

main

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

main method

Parameters:

args - system arguments

Throws:

Exception - any errors from Hive Giraph Runner

run

public final int run(String[] args)
              throws Exception

Specified by:

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

Throws:

Exception

getConf

public final org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public final void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

addMoreOptions

protected void addMoreOptions(org.apache.commons.cli.Options options)

Override this method to add more command-line options. You can process them by also overriding processMoreArguments(CommandLine).

Parameters:

options - Options

processMoreArguments

protected void processMoreArguments(org.apache.commons.cli.CommandLine cmd)

Override this method to process additional command-line arguments. You may want to declare additional options by also overriding addMoreOptions(Options).

Parameters:

cmd - Command

initGiraphJob

protected void initGiraphJob(GiraphJob job)

Override this method to do additional setup with the GiraphJob that will run.

Parameters:

job - GiraphJob that is going to run