com.asakusafw.runtime.stage.input

Class StageInputDriver

java.lang.Object

com.asakusafw.runtime.stage.input.StageInputDriver

public final class StageInputDriver
extends Object

A driver for configuring stage inputs.

Since:

0.1.0

Version:

0.6.0

Method Summary

Modifier and Type	Method and Description
static long	estimateInputSize(org.apache.hadoop.mapreduce.JobContext context) Returns the estimated input data-size.
static void	set(org.apache.hadoop.mapreduce.Job job, List<StageInput> inputList) Sets the input specification for this job.

Methods inherited from class java.lang.Object

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

Method Detail

set

public static void set(org.apache.hadoop.mapreduce.Job job,
                       List<StageInput> inputList)

Sets the input specification for this job.

Parameters:

job - current job

inputList - each input specification

Throws:

IllegalArgumentException - if some parameters were null

Since:

0.2.5

estimateInputSize

public static long estimateInputSize(org.apache.hadoop.mapreduce.JobContext context)
                              throws InterruptedException

Returns the estimated input data-size.

Parameters:

context - the current job context

Returns:

the estimated input data-size in bytes

Throws:

InterruptedException - if interrupted while

IllegalArgumentException - if some parameters were null

Since:

0.6.0