org.apache.crunch.test

Class CrunchTestSupport

java.lang.Object

org.apache.crunch.test.CrunchTestSupport

public class CrunchTestSupport
extends Object

A temporary workaround for Scala tests to use when working with Rule annotations until it gets fixed in JUnit 4.11.

Field Summary

Fields

Modifier and Type	Field and Description
TemporaryPath	tempDir

Constructor Summary

Constructors

Constructor and Description
CrunchTestSupport()

Method Summary

Methods

Modifier and Type	Method and Description
static <KI,VI,KO,VO> org.apache.hadoop.mapreduce.TaskInputOutputContext<KI,VI,KO,VO>	getTestContext(org.apache.hadoop.conf.Configuration config) The method creates a TaskInputOutputContext which can be used in unit tests.

Methods inherited from class java.lang.Object

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

Field Detail

tempDir

public TemporaryPath tempDir

Constructor Detail

CrunchTestSupport

public CrunchTestSupport()

Method Detail

getTestContext

public static <KI,VI,KO,VO> org.apache.hadoop.mapreduce.TaskInputOutputContext<KI,VI,KO,VO> getTestContext(org.apache.hadoop.conf.Configuration config)

The method creates a TaskInputOutputContext which can be used in unit tests. The context serves very limited purpose. You can only operate with counters, taskAttempId, status and configuration while using this context.