SELECT * FROM TABLE(my_stored_function)

input {
    jdbc {
        jdbc_validate_connection => true
        jdbc_connection_string => "jdbc:oracle:thin:@mycomp:1522/db1"
        ...
        statement => "SELECT * FROM TABLE(my_stored_function)"
       }
}
output {
    stdout { codec => rubydebug }
        elasticsearch {
            doc_as_upsert => true
            action => "update"
            index => "contacts"
            document_type => "contact"
            document_id => "%{id}"
            hosts => ["http://localhost:9200"]
    }
}