felix.io
Class TestHadoop.Reduce

java.lang.Object
  org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
      felix.io.TestHadoop.Reduce

Enclosing class:

TestHadoop

public static class TestHadoop.Reduce
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

REDUCE

Author:

czhang

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Reducer

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

static java.lang.String	_inputkey
static java.lang.String	_inputvalues
static PythonExecutor	pyReducer

Constructor Summary

TestHadoop.Reduce()

Method Summary

void	setup(org.apache.hadoop.mapreduce.Reducer.Context contex)

Methods inherited from class org.apache.hadoop.mapreduce.Reducer

run

Methods inherited from class java.lang.Object

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

Field Detail

pyReducer

public static PythonExecutor pyReducer

_inputkey

public static java.lang.String _inputkey

_inputvalues

public static java.lang.String _inputvalues

Constructor Detail

TestHadoop.Reduce

public TestHadoop.Reduce()

Method Detail

setup

public void setup(org.apache.hadoop.mapreduce.Reducer.Context contex)

Overrides:

setup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>