Module: Elasticsearch::XPack::API::DataFrame::Actions
- Included in:
- Graph::DataFrameClient
- Defined in:
- lib/elasticsearch/xpack/api/actions/data_frame/get_data_frame_transform.rb,
lib/elasticsearch/xpack/api/actions/data_frame/put_data_frame_transform.rb,
lib/elasticsearch/xpack/api/actions/data_frame/stop_data_frame_transform.rb,
lib/elasticsearch/xpack/api/actions/data_frame/start_data_frame_transform.rb,
lib/elasticsearch/xpack/api/actions/data_frame/delete_data_frame_transform.rb,
lib/elasticsearch/xpack/api/actions/data_frame/preview_data_frame_transform.rb,
lib/elasticsearch/xpack/api/actions/data_frame/get_data_frame_transform_stats.rb
Instance Method Summary collapse
-
#delete_data_frame_transform(arguments = {}) ⇒ Object
Deletes an existing data frame transform.
-
#get_data_frame_transform(arguments = {}) ⇒ Object
Retrieves configuration information for data frame transforms.
-
#get_data_frame_transform_stats(arguments = {}) ⇒ Object
Retrieves usage information for data frame transforms.
-
#preview_data_frame_transform(arguments = {}) ⇒ Object
Previews a data frame transform.
-
#put_data_frame_transform(arguments = {}) ⇒ Object
Instantiates a data frame transform.
-
#start_data_frame_transform(arguments = {}) ⇒ Object
Start a data frame analytics job.
-
#stop_data_frame_transform(arguments = {}) ⇒ Object
Stops one or more data frame transforms.
Instance Method Details
#delete_data_frame_transform(arguments = {}) ⇒ Object
Deletes an existing data frame transform.
18 19 20 21 22 23 24 25 26 27 28 |
# File 'lib/elasticsearch/xpack/api/actions/data_frame/delete_data_frame_transform.rb', line 18 def delete_data_frame_transform(arguments={}) raise ArgumentError, "Required argument 'transform_id' missing" unless arguments[:transform_id] transform_id = URI.escape(arguments[:transform_id]) method = Elasticsearch::API::HTTP_DELETE path = "_data_frame/transforms/#{transform_id}" params = {} body = nil perform_request(method, path, params, body).body end |
#get_data_frame_transform(arguments = {}) ⇒ Object
Retrieves configuration information for data frame transforms.
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 |
# File 'lib/elasticsearch/xpack/api/actions/data_frame/get_data_frame_transform.rb', line 21 def get_data_frame_transform(arguments={}) arguments = arguments.clone transform_id = URI.escape(arguments.delete(:transform_id)) valid_params = [ :from, :size, :allow_no_match] method = Elasticsearch::API::HTTP_GET path = Elasticsearch::API::Utils.__pathify('_data_frame/transforms', Elasticsearch::API::Utils.__listify(transform_id)) params = Elasticsearch::API::Utils.__validate_and_extract_params(arguments, valid_params) body = nil perform_request(method, path, params, body).body end |
#get_data_frame_transform_stats(arguments = {}) ⇒ Object
Retrieves usage information for data frame transforms.
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 |
# File 'lib/elasticsearch/xpack/api/actions/data_frame/get_data_frame_transform_stats.rb', line 21 def get_data_frame_transform_stats(arguments={}) arguments = arguments.clone transform_id = URI.escape(arguments.delete(:transform_id)) valid_params = [ :from, :size] method = Elasticsearch::API::HTTP_GET path = Elasticsearch::API::Utils.__pathify('_data_frame/transforms', Elasticsearch::API::Utils.__listify(transform_id), '_stats') params = Elasticsearch::API::Utils.__validate_and_extract_params(arguments, valid_params) body = nil perform_request(method, path, params, body).body end |
#preview_data_frame_transform(arguments = {}) ⇒ Object
Previews a data frame transform.
18 19 20 21 22 23 24 25 26 |
# File 'lib/elasticsearch/xpack/api/actions/data_frame/preview_data_frame_transform.rb', line 18 def preview_data_frame_transform(arguments={}) raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] method = Elasticsearch::API::HTTP_POST path = '_data_frame/transforms/_preview' params = {} body = arguments[:body] perform_request(method, path, params, body).body end |
#put_data_frame_transform(arguments = {}) ⇒ Object
Instantiates a data frame transform.
19 20 21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/elasticsearch/xpack/api/actions/data_frame/put_data_frame_transform.rb', line 19 def put_data_frame_transform(arguments={}) raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'transform_id' missing" unless arguments[:transform_id] transform_id = URI.escape(arguments[:transform_id]) body = arguments[:body] method = Elasticsearch::API::HTTP_PUT path = "_data_frame/transforms/#{transform_id}" params = {} perform_request(method, path, params, body).body end |
#start_data_frame_transform(arguments = {}) ⇒ Object
Start a data frame analytics job.
19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
# File 'lib/elasticsearch/xpack/api/actions/data_frame/start_data_frame_transform.rb', line 19 def start_data_frame_transform(arguments={}) raise ArgumentError, "Required argument 'transform_id' missing" unless arguments[:transform_id] arguments = arguments.clone transform_id = URI.escape(arguments.delete(:transform_id)) valid_params = [ :timeout] method = Elasticsearch::API::HTTP_POST path = "_data_frame/transforms/#{transform_id}/_start" params = Elasticsearch::API::Utils.__validate_and_extract_params arguments, valid_params body = nil perform_request(method, path, params, body).body end |
#stop_data_frame_transform(arguments = {}) ⇒ Object
Stops one or more data frame transforms.
22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/elasticsearch/xpack/api/actions/data_frame/stop_data_frame_transform.rb', line 22 def stop_data_frame_transform(arguments={}) raise ArgumentError, "Required argument 'transform_id' missing" unless arguments[:transform_id] arguments = arguments.clone transform_id = URI.escape(arguments.delete(:transform_id)) valid_params = [ :timeout, :wait_for_completion, :allow_no_match ] method = Elasticsearch::API::HTTP_POST path = "_data_frame/transforms/#{Elasticsearch::API::Utils.__listify(transform_id)}/_stop" params = Elasticsearch::API::Utils.__validate_and_extract_params(arguments, valid_params) body = nil perform_request(method, path, params, body).body end |