org.apache.crunch.lambda

Interface LDoFnContext<S,T>

Type Parameters:

S - Input type of LDoFn

T - Output type of LDoFn

public interface LDoFnContext<S,T>

Context object for implementing distributed operations in terms of Lambda expressions.

Method Summary

Modifier and Type	Method and Description
S	element() Get the input element
void	emit(T t) Emit t to the output
org.apache.hadoop.conf.Configuration	getConfiguration() Get the current Hadoop Configuration
org.apache.hadoop.mapreduce.TaskInputOutputContext	getContext() Get the underlying TaskInputOutputContext (for special cases)
void	increment(Enum<?> counterName) Increment a counter by 1
void	increment(Enum<?> counterName, long value) Increment a counter by value
void	increment(String groupName, String counterName) Increment a counter by 1
void	increment(String groupName, String counterName, long value) Increment a counter by value

Method Detail

element

S element()

Get the input element

emit

void emit(T t)

Emit t to the output

getContext

org.apache.hadoop.mapreduce.TaskInputOutputContext getContext()

Get the underlying TaskInputOutputContext (for special cases)

getConfiguration

org.apache.hadoop.conf.Configuration getConfiguration()

Get the current Hadoop Configuration

increment

void increment(String groupName,
               String counterName)

Increment a counter by 1

increment

void increment(String groupName,
               String counterName,
               long value)

Increment a counter by value

increment

void increment(Enum<?> counterName)

Increment a counter by 1

increment

void increment(Enum<?> counterName,
               long value)

Increment a counter by value