This project has retired. For details please refer to its Attic page.

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

TemporaryPath

tempDir

Constructor Summary

CrunchTestSupport()

Method Summary

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.