Top Level Namespace

Defined Under Namespace

Classes: CopyMap, CopyReduce, JobBase, LinearRegression, MapBase, MaxReduce, MaxUniqueSumReduce, MinReduce, ReduceBase, SampleReduce, SelectMap, Stage, StreamIO, StreamRunner, SumReduce, UniqueCountReduce, UniqueFirstReduce, UniqueIndexedCountReduce, UniqueIndexedSumReduce, UniqueReduce, UniqueSumReduce

Constant Summary

HADOOP_HOME =

ENV['HADOOP_HOME']

HADOOP_STREAMING =

Dir.glob("#{HADOOP_HOME}/contrib/streaming/hadoop*streaming*.jar").find{|f| f.include?(streaming_version)}