lib/wonderdog.rb in wonderdog-0.1.1 vs lib/wonderdog.rb in wonderdog-0.2.0

@@ -24,9 +24,12 @@
       settings.define(:es_index_field,    :description => "Field to use from each record to override the default index", :wukong_hadoop => true)
       settings.define(:es_mapping_field,  :description => "Field to use from each record to override the default mapping", :wukong_hadoop => true)
       settings.define(:es_id_field,       :description => "If this field is present in a record, make an update request, otherwise make a create request", :wukong_hadoop => true)
       settings.define(:es_bulk_size,      :description => "Number of requests to batch locally before making a request to ElasticSearch", :type => Integer, :wukong_hadoop => true)
       settings.define(:es_query,          :description => "Query to use when defining input splits for ElasticSearch input",    :wukong_hadoop => true)
+      settings.define(:es_transport,      :description => "Use a transport client to an existing node instead of spinning up a new node", :default => true, type: :boolean, :wukong_hadoop => true)
+      settings.define(:es_transport_host, :description => "Host of existing node for transport client", default: 'localhost', :wukong_hadoop => true)
+      settings.define(:es_transport_port, :description => "Port of existing node for transport client", default: 9300, type: Integer, :wukong_hadoop => true)
     end
 
     # Boot Wonderdog with the given `settings` in the given `dir`.
     #
     # @param [Configliere::Param] settings