input {
            jdbc {
                jdbc_connection_string => "jdbc:mysql://localhost/elasticsearch"
                jdbc_user => "root"
                jdbc_password => "empower"
                #jdbc_validate_connection => true
                jdbc_driver_library => "/home/wtc082/Documents/com.mysql.jdbc_5.1.5.jar"
                jdbc_driver_class => "com.mysql.jdbc.Driver"
                statement => "SELECT * FROM index_part_content_local LIMIT 10;"
                schedule => "1 * * * *"
                #codec => "json"
            }
        }

    output {
        elasticsearch {
            index => "mysqltest"
            document_type => "mysqltest_type"
            document_id => "%{partnum}"
            hosts => "AWSURI"
        }
    }