A B C D F G H M N O P R S W

A

AnnotatedWordCount - Class in com.conversantmedia.mapreduce.example

AnnotatedWordCount() - Constructor for class com.conversantmedia.mapreduce.example.AnnotatedWordCount

AnnotatedWordCountWithListener - Class in com.conversantmedia.mapreduce.example

AnnotatedWordCountWithListener() - Constructor for class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener

AnnotatedWordCountWithListener.WordCountListener - Class in com.conversantmedia.mapreduce.example

AvroExample - Class in com.dotomi.mapreduce.example.avro

AvroExample() - Constructor for class com.dotomi.mapreduce.example.avro.AvroExample

Default constructor.

AvroExample(CharSequence, Long) - Constructor for class com.dotomi.mapreduce.example.avro.AvroExample

All-args constructor.

AvroExample.Builder - Class in com.dotomi.mapreduce.example.avro

RecordBuilder for AvroExample instances.

AvroInputOutputExample - Class in com.conversantmedia.mapreduce.example.avro

AvroInputOutputExample() - Constructor for class com.conversantmedia.mapreduce.example.avro.AvroInputOutputExample

AvroInputOutputExample.AvroWordFrequencyMapper - Class in com.conversantmedia.mapreduce.example.avro

AvroMultipleOutputExample - Class in com.conversantmedia.mapreduce.example.avro

This is an example job that writes output to an AvroNamedOutput.

AvroMultipleOutputExample() - Constructor for class com.conversantmedia.mapreduce.example.avro.AvroMultipleOutputExample

AvroWordCountReducer - Class in com.conversantmedia.mapreduce.example.avro

AvroWordCountReducer() - Constructor for class com.conversantmedia.mapreduce.example.avro.AvroWordCountReducer

AvroWordFrequencyMapper() - Constructor for class com.conversantmedia.mapreduce.example.avro.AvroInputOutputExample.AvroWordFrequencyMapper

B

BlacklistContext() - Constructor for class com.conversantmedia.mapreduce.example.WordCountWithBlacklist.BlacklistContext

build() - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

C

cleanup() - Method in class com.conversantmedia.mapreduce.example.PrepareInputsExample

clearFrequency() - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Clears the value of the 'frequency' field

clearWord() - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Clears the value of the 'word' field

com.conversantmedia.mapreduce.example - package com.conversantmedia.mapreduce.example

com.conversantmedia.mapreduce.example.avro - package com.conversantmedia.mapreduce.example.avro

com.conversantmedia.mapreduce.example.distribute - package com.conversantmedia.mapreduce.example.distribute

com.dotomi.mapreduce.example.avro - package com.dotomi.mapreduce.example.avro

copyFilesToWorking() - Method in class com.conversantmedia.mapreduce.example.PrepareInputsExample

D

DistributedObjectExample - Class in com.conversantmedia.mapreduce.example.distribute

DistributedObjectExample() - Constructor for class com.conversantmedia.mapreduce.example.distribute.DistributedObjectExample

DistributedObjectExample.WordcountContext - Class in com.conversantmedia.mapreduce.example.distribute

Custom context.

F

frequency - Variable in class com.dotomi.mapreduce.example.avro.AvroExample

Deprecated.

G

get(int) - Method in class com.dotomi.mapreduce.example.avro.AvroExample

getBlacklist() - Method in class com.conversantmedia.mapreduce.example.distribute.DistributedObjectExample

Distributed Set containing the prepared list of blacklisted words.

getBlacklist() - Method in class com.conversantmedia.mapreduce.example.WordCountWithBlacklist

getClassSchema() - Static method in class com.dotomi.mapreduce.example.avro.AvroExample

getFrequency() - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Gets the value of the 'frequency' field

getFrequency() - Method in class com.dotomi.mapreduce.example.avro.AvroExample

Gets the value of the 'frequency' field.

getMinimum() - Method in class com.conversantmedia.mapreduce.example.distribute.DistributedObjectExample.WordcountContext

getSchema() - Method in class com.dotomi.mapreduce.example.avro.AvroExample

getWord() - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Gets the value of the 'word' field

getWord() - Method in class com.dotomi.mapreduce.example.avro.AvroExample

Gets the value of the 'word' field.

getWorkingDirectory() - Method in class com.conversantmedia.mapreduce.example.PrepareInputsExample

H

hasFrequency() - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Checks whether the 'frequency' field has been set

hasWord() - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Checks whether the 'word' field has been set

M

main(String[]) - Static method in class com.conversantmedia.mapreduce.example.WordCount

map(AvroKey<AvroExample>, NullWritable, Mapper<AvroKey<AvroExample>, NullWritable, AvroKey<AvroExample>, NullWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.avro.AvroInputOutputExample.AvroWordFrequencyMapper

map(LongWritable, Text, Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.distribute.WordCountWithBlacklistMapper2

map(LongWritable, Text, Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.NamedOutputWordCountMapper

map(LongWritable, Text, Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.WordCountMapper

map(LongWritable, Text, Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.WordCountWithBlacklistMapper

MinimumWordCountContext() - Constructor for class com.conversantmedia.mapreduce.example.WordCountWithMinimum.MinimumWordCountContext

N

NamedOutputsExample - Class in com.conversantmedia.mapreduce.example

NamedOutputsExample() - Constructor for class com.conversantmedia.mapreduce.example.NamedOutputsExample

NamedOutputWordCountMapper - Class in com.conversantmedia.mapreduce.example

NamedOutputWordCountMapper() - Constructor for class com.conversantmedia.mapreduce.example.NamedOutputWordCountMapper

newBuilder() - Static method in class com.dotomi.mapreduce.example.avro.AvroExample

Creates a new AvroExample RecordBuilder

newBuilder(AvroExample.Builder) - Static method in class com.dotomi.mapreduce.example.avro.AvroExample

Creates a new AvroExample RecordBuilder by copying an existing Builder

newBuilder(AvroExample) - Static method in class com.dotomi.mapreduce.example.avro.AvroExample

Creates a new AvroExample RecordBuilder by copying an existing AvroExample instance

O

onAfterInitCliOptions(ToolEvent<DriverContextBase>, Options) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

onAfterMapReduceFinish(int, ToolEvent<DriverContextBase>) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

onAfterParseCli(ToolEvent<DriverContextBase>, CommandLine) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

onBeforeExit(ToolEvent<DriverContextBase>) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

onBeforeInitDriver(String, ToolEvent<DriverContextBase>) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

onBeforeInitJob(ToolEvent<DriverContextBase>) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

onBeforeMapReduceSubmit(ToolEvent<DriverContextBase>) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

onJobException(ToolEvent<DriverContextBase>, Exception) - Method in class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

P

PrepareInputsExample - Class in com.conversantmedia.mapreduce.example

In this example we will do some pre-processing on the inputs (copy to a 'working' directory) before kicking off the job.

PrepareInputsExample() - Constructor for class com.conversantmedia.mapreduce.example.PrepareInputsExample

put(int, Object) - Method in class com.dotomi.mapreduce.example.avro.AvroExample

R

reduce(Text, Iterable<LongWritable>, Reducer<Text, LongWritable, AvroKey<AvroExample>, NullWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.avro.AvroWordCountReducer

reduce(Text, Iterable<LongWritable>, Reducer<Text, LongWritable, Text, LongWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.WordCountReducer

reduce(Text, Iterable<LongWritable>, Reducer<Text, LongWritable, Text, LongWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.WordCountReducerWithMinimum

S

SCHEMA$ - Static variable in class com.dotomi.mapreduce.example.avro.AvroExample

setFrequency(long) - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Sets the value of the 'frequency' field

setFrequency(Long) - Method in class com.dotomi.mapreduce.example.avro.AvroExample

Sets the value of the 'frequency' field.

setup(Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class com.conversantmedia.mapreduce.example.WordCountWithBlacklistMapper

setWord(CharSequence) - Method in class com.dotomi.mapreduce.example.avro.AvroExample.Builder

Sets the value of the 'word' field

setWord(CharSequence) - Method in class com.dotomi.mapreduce.example.avro.AvroExample

Sets the value of the 'word' field.

W

word - Variable in class com.dotomi.mapreduce.example.avro.AvroExample

Deprecated.

WordCount - Class in com.conversantmedia.mapreduce.example

Classic MapReduce 'WordCount' Driver (new API).

WordCount() - Constructor for class com.conversantmedia.mapreduce.example.WordCount

WordcountContext() - Constructor for class com.conversantmedia.mapreduce.example.distribute.DistributedObjectExample.WordcountContext

WordCountListener() - Constructor for class com.conversantmedia.mapreduce.example.AnnotatedWordCountWithListener.WordCountListener

WordCountMapper - Class in com.conversantmedia.mapreduce.example

WordCountMapper() - Constructor for class com.conversantmedia.mapreduce.example.WordCountMapper

WordCountReducer - Class in com.conversantmedia.mapreduce.example

WordCountReducer() - Constructor for class com.conversantmedia.mapreduce.example.WordCountReducer

WordCountReducerWithMinimum - Class in com.conversantmedia.mapreduce.example

WordCountReducerWithMinimum() - Constructor for class com.conversantmedia.mapreduce.example.WordCountReducerWithMinimum

WordCountWithBlacklist - Class in com.conversantmedia.mapreduce.example

WordCountWithBlacklist() - Constructor for class com.conversantmedia.mapreduce.example.WordCountWithBlacklist

WordCountWithBlacklist.BlacklistContext - Class in com.conversantmedia.mapreduce.example

WordCountWithBlacklistMapper - Class in com.conversantmedia.mapreduce.example

WordCountWithBlacklistMapper() - Constructor for class com.conversantmedia.mapreduce.example.WordCountWithBlacklistMapper

WordCountWithBlacklistMapper2 - Class in com.conversantmedia.mapreduce.example.distribute

WordCountWithBlacklistMapper2() - Constructor for class com.conversantmedia.mapreduce.example.distribute.WordCountWithBlacklistMapper2

WordCountWithMinimum - Class in com.conversantmedia.mapreduce.example

WordCountWithMinimum() - Constructor for class com.conversantmedia.mapreduce.example.WordCountWithMinimum

WordCountWithMinimum.MinimumWordCountContext - Class in com.conversantmedia.mapreduce.example

A B C D F G H M N O P R S W