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