github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

remove old logging lines

Browse source
This commit is contained in:
Evan Livingston 2013-05-18 03:04:26 +00:00
parent 9a7184bde8
commit a22e7999ac
1 changed files with 0 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
lib/logstash/inputs/sqlite.rb
View file

@ -61,7 +61,6 @@ class LogStash::Inputs::Sqlite < LogStash::Inputs::Base
public
def get_n_rows_from_table(db, table, offset, limit)
#@logger.debug("Selecting from #{table} where id is at least #{offset}")
dataset = db["SELECT * FROM #{table}"]
return db["SELECT * FROM #{table} WHERE (id >= #{offset}) ORDER BY 'id' LIMIT #{limit}"].map { |row| row }
end
@ -96,7 +95,6 @@ class LogStash::Inputs::Sqlite < LogStash::Inputs::Base
lines = get_n_rows_from_table(@DB, table_name, offset, limit)
lines.each{ |line|
line.delete(:id)
#@logger.debug(line.class)
entry = {}
line.each { |name,element|
entry["@#{name}"] = element