class LogStash::Outputs::HDFS::DFSOutputStreamWrapper

Constants

FLUSH_METHOD

hadoop 2.x uses hflush

Attributes

active[RW]

Public Class Methods

new(output_stream) click to toggle source
# File lib/logstash/outputs/hdfs.rb, line 192
def initialize(output_stream)
  @output_stream = output_stream
end

Public Instance Methods

close() click to toggle source
# File lib/logstash/outputs/hdfs.rb, line 195
def close
  @output_stream.close
rescue IOException => e
  logger.error("Failed to close file", :exception => e)
end
flush() click to toggle source
# File lib/logstash/outputs/hdfs.rb, line 200
def flush
  if FLUSH_METHOD == :hflush
    @output_stream.hflush
  else
    @output_stream.flush
    @output_stream.sync
  end
rescue

end
write(str) click to toggle source
# File lib/logstash/outputs/hdfs.rb, line 210
def write(str)
  bytes = str.to_java_bytes
  @output_stream.write(bytes, 0, bytes.length)
  @active = true
end