Module: Rubadoop::MapReduce::Io

Included in:
Rubadoop::MapReduce
Defined in:
lib/rubadoop/map_reduce/io.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Attribute Details

#io_errObject



12
# File 'lib/rubadoop/map_reduce/io.rb', line 12

def io_err; @io_err || STDERR end

#io_inObject



10
# File 'lib/rubadoop/map_reduce/io.rb', line 10

def io_in;  @io_in  || STDIN  end

#io_outObject



11
# File 'lib/rubadoop/map_reduce/io.rb', line 11

def io_out; @io_out || STDOUT end

#outObject



7
8
9
# File 'lib/rubadoop/map_reduce/io.rb', line 7

def out
  @out ||= HadoopOut.new
end

Class Method Details

.set_rails_outputObject



21
22
23
# File 'lib/rubadoop/map_reduce/io.rb', line 21

def set_rails_output
  ::Rubadoop::MapReduce.out = RailsOut.new
end

.set_silent_outputObject



15
16
17
# File 'lib/rubadoop/map_reduce/io.rb', line 15

def set_silent_output
  ::Rubadoop::MapReduce.out = EmptyOut.new
end

.set_standard_outputObject



18
19
20
# File 'lib/rubadoop/map_reduce/io.rb', line 18

def set_standard_output
  ::Rubadoop::MapReduce.out = StandardOut.new
end