logstash-tenis.conf

input {
    file {
    	path => "/data/all_players.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_matches_p1.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_matches_p2.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_matches_p3.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_matches_p4.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_matches_p5.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_matches_p6.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_matches_p7.csv"
    	start_position => "beginning"
    }
    file {
    	path => "/data/all_tournaments_p1.csv"
    	start_position => "beginning"
    }
}    
              
filter {
	if [path] == "/data/all_players.csv"{
		csv {
			separator => ","
			columns => ["player_id", "country"]
		}
	}
	else if [path] == "/data/all_tournaments_p1.csv"{
		csv {
			separator => ","
			columns => ["year", "tournament", "start_date", "end_date", "location", "court_surface"]
		}
	}
	else if [path] == "/data/all_matches_p1.csv" or [path] == "/data/all_matches_p2.csv" or [path] == "/data/all_matches_p3.csv" or [path] == "/data/all_matches_p4.csv" or [path] == "/data/all_matches_p5.csv" or [path] == "/data/all_matches_p6.csv" or [path] == "/data/all_matches_p7.csv" {
		csv {
			separator => ","
			columns => ["start_date", "court_surface", "year", "player_id", "opponent_id", "tournament", "num_sets", "sets_won", "games_won", "games_against", "tiebreaks_won", "tiebreaks_total", "player_victory", "retirement", "won_first_set", "doubles"]
		}
	}
}

output {
    elasticsearch{
        hosts => ["localhost"]
    }	
}