Contents

module Embulk
  module Input
    class Presto < InputPlugin
      class Connection
        def self.get_client(task)
          ::Presto::Client.new(
            server: "#{task['host']}:#{task['port']}",
            catalog: task['catalog'],
            user: task['user'],
            schema: task['schema']
          )
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
embulk-input-presto-0.2.5	lib/embulk/input/presto/connection.rb
embulk-input-presto-0.2.4	lib/embulk/input/presto/connection.rb
embulk-input-presto-0.2.3	lib/embulk/input/presto/connection.rb
embulk-input-presto-0.2.2	lib/embulk/input/presto/connection.rb
embulk-input-presto-0.2.1	lib/embulk/input/presto/connection.rb
embulk-input-presto-0.2.0	lib/embulk/input/presto/connection.rb