input {
    jdbc {
        jdbc_driver_library => "mysql-connector-java-5.1.39-bin.jar"
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        jdbc_connection_string => "jdbc:mysql://gratiadb03.fnal.gov:3306/gratia"
        jdbc_user => "reader"
        jdbc_password => "XXXXXXXXXXX"
        statement => '
select
    m.SummaryID,
    m.EndTime as "@timestamp",
    m.CommonName as "CommonName",
    m.WallDuration*m.Cores/2600 as "CoreHours",
    m.Njobs as "Count",
    m.CpuSystemDuration as "CpuDuration_system",
    m.CpuUserDuration as "CpuDuration_user",
    m.DistinguishedName as "DN",
    m.EndTime as "EndTime",
    m.Grid as "Grid",
    m.HostDescription as "Host_description",
    m.ProbeName as "ProbeName",
    m.Cores as "Processors",
    p.ReportableProjectName as "ProjectName",
    p.ReportableProjectName as "RawProjectName",
    v.VOName as "RawVOName",
    v.ReportableVOName as "ReportableVOName",
    m.ApplicationExitCode as "Resource_ExitCode",
    m.ResourceType as "ResourceType",
    s.SiteName as "SiteName",
    vo.VOName as "VOName",
    m.WallDuration as "WallDuration"
 from
    MasterSummaryData m
    join ProjectNameCorrection p using (ProjectNameCorrid)
    join VONameCorrection v
    join VO vo
    join Probe pb
    join Site s using (siteid)
 where
    m.VOcorrid=v.corrid
    AND v.VOid=vo.VOid
    AND pb.probename=m.ProbeName
    AND EndTime < makedate(2015,17)'
        lowercase_column_names => false
        type => "JobUsageRecordSummary"
    }
}
filter {
    mutate {
        convert => {"Resource_ExitCode" => "integer"}
    }
}
output {
    #stdout { codec => "rubydebug" }
    elasticsearch {
        hosts => [ "localhost" ]
        index => "gratia.osg.summary0"
        document_id => "%{SummaryID}"
    }
}