Module: Mandy

Defined in:
lib/mandy.rb,
lib/mandy/dsl.rb,
lib/mandy/job.rb,
lib/mandy/task.rb,
lib/mandy/errors.rb,
lib/mandy/packer.rb,
lib/mandy/test_runner.rb,
lib/mandy/stores/hbase.rb,
lib/mandy/support/tuple.rb,
lib/mandy/serializers/json.rb,
lib/mandy/stores/in_memory.rb,
lib/mandy/support/formatting.rb,
lib/mandy/mappers/base_mapper.rb,
lib/mandy/reducers/max_reducer.rb,
lib/mandy/reducers/min_reducer.rb,
lib/mandy/reducers/sum_reducer.rb,
lib/mandy/reducers/base_reducer.rb,
lib/mandy/support/hdfs_location.rb,
lib/mandy/mappers/transpose_mapper.rb,
lib/mandy/support/array_serializer.rb,
lib/mandy/reducers/transpose_reducer.rb,
lib/mandy/mappers/pass_through_mapper.rb,
lib/mandy/reducers/pass_through_reducer.rb

Defined Under Namespace

Modules: DSL, IO, Mappers, Reducers, Serializers, Stores Classes: ArraySerializer, HadoopJobFailure, HdfsLocation, Job, Packer, Task, TestRunner, Tuple

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.autorun ⇒ Object

Returns the value of attribute autorun.



39
40
41
 
# File 'lib/mandy.rb', line 39

def autorun
  @autorun
end

.local_input ⇒ Object

Returns the value of attribute local_input.



38
39
40
 
# File 'lib/mandy.rb', line 38

def local_input
  @local_input
end

Class Method Details

.job(name, &blk) ⇒ Object 



45
46
47
48
49
50
 
# File 'lib/mandy.rb', line 45

def job(name, &blk)
  job = Mandy::Job.new(name)
  job.instance_eval(&blk) unless blk.nil?
  Mandy::Job.jobs << job
  job
end

.parameter(name) ⇒ Object 



53
54
55
 
# File 'lib/mandy.rb', line 53

def parameter(name)
  Mandy::Job.parameter(name)
end

.stores ⇒ Object 



40
41
42
 
# File 'lib/mandy.rb', line 40

def stores
  @stores||={}
end