com.conversantmedia.mapreduce.example.distribute

Class DistributedObjectExample

java.lang.Object

com.conversantmedia.mapreduce.example.distribute.DistributedObjectExample

@Driver(value="distributed-blacklist",
        description="Demonstrates distributing an object resource to the M/R framework components.")
public class DistributedObjectExample
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DistributedObjectExample.WordcountContext Custom context.

Constructor Summary

Constructors

Constructor and Description
DistributedObjectExample()

Method Summary

Modifier and Type	Method and Description
Set<String>	getBlacklist() Distributed Set containing the prepared list of blacklisted words.

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedObjectExample

public DistributedObjectExample()

Method Detail

getBlacklist

@Distribute
public Set<String> getBlacklist()
                                     throws IOException

Distributed Set containing the prepared list of blacklisted words.

Returns:

Set the set of blacklisted words

Throws:

IOException - if it fails to read in the file