lib/aws-sdk-datazone/client.rb in aws-sdk-datazone-1.11.0 vs lib/aws-sdk-datazone/client.rb in aws-sdk-datazone-1.12.0
- old
+ new
@@ -3992,10 +3992,88 @@
def get_iam_portal_login_url(params = {}, options = {})
req = build_request(:get_iam_portal_login_url, params)
req.send_request(options)
end
+ # Gets the data lineage node.
+ #
+ # @option params [required, String] :domain_identifier
+ # The ID of the domain in which you want to get the data lineage node.
+ #
+ # @option params [Time,DateTime,Date,Integer,String] :event_timestamp
+ # The event time stamp for which you want to get the data lineage node.
+ #
+ # @option params [required, String] :identifier
+ # The ID of the data lineage node that you want to get.
+ #
+ # Both, a lineage node identifier generated by Amazon DataZone and a
+ # `sourceIdentifier` of the lineage node are supported. If
+ # `sourceIdentifier` is greater than 1800 characters, you can use
+ # lineage node identifier generated by Amazon DataZone to get the node
+ # details.
+ #
+ # @return [Types::GetLineageNodeOutput] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::GetLineageNodeOutput#created_at #created_at} => Time
+ # * {Types::GetLineageNodeOutput#created_by #created_by} => String
+ # * {Types::GetLineageNodeOutput#description #description} => String
+ # * {Types::GetLineageNodeOutput#domain_id #domain_id} => String
+ # * {Types::GetLineageNodeOutput#downstream_nodes #downstream_nodes} => Array<Types::LineageNodeReference>
+ # * {Types::GetLineageNodeOutput#event_timestamp #event_timestamp} => Time
+ # * {Types::GetLineageNodeOutput#forms_output #forms_output} => Array<Types::FormOutput>
+ # * {Types::GetLineageNodeOutput#id #id} => String
+ # * {Types::GetLineageNodeOutput#name #name} => String
+ # * {Types::GetLineageNodeOutput#source_identifier #source_identifier} => String
+ # * {Types::GetLineageNodeOutput#type_name #type_name} => String
+ # * {Types::GetLineageNodeOutput#type_revision #type_revision} => String
+ # * {Types::GetLineageNodeOutput#updated_at #updated_at} => Time
+ # * {Types::GetLineageNodeOutput#updated_by #updated_by} => String
+ # * {Types::GetLineageNodeOutput#upstream_nodes #upstream_nodes} => Array<Types::LineageNodeReference>
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.get_lineage_node({
+ # domain_identifier: "DomainId", # required
+ # event_timestamp: Time.now,
+ # identifier: "LineageNodeIdentifier", # required
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.created_at #=> Time
+ # resp.created_by #=> String
+ # resp.description #=> String
+ # resp.domain_id #=> String
+ # resp.downstream_nodes #=> Array
+ # resp.downstream_nodes[0].event_timestamp #=> Time
+ # resp.downstream_nodes[0].id #=> String
+ # resp.event_timestamp #=> Time
+ # resp.forms_output #=> Array
+ # resp.forms_output[0].content #=> String
+ # resp.forms_output[0].form_name #=> String
+ # resp.forms_output[0].type_name #=> String
+ # resp.forms_output[0].type_revision #=> String
+ # resp.id #=> String
+ # resp.name #=> String
+ # resp.source_identifier #=> String
+ # resp.type_name #=> String
+ # resp.type_revision #=> String
+ # resp.updated_at #=> Time
+ # resp.updated_by #=> String
+ # resp.upstream_nodes #=> Array
+ # resp.upstream_nodes[0].event_timestamp #=> Time
+ # resp.upstream_nodes[0].id #=> String
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/datazone-2018-05-10/GetLineageNode AWS API Documentation
+ #
+ # @overload get_lineage_node(params = {})
+ # @param [Hash] params ({})
+ def get_lineage_node(params = {}, options = {})
+ req = build_request(:get_lineage_node, params)
+ req.send_request(options)
+ end
+
# Gets a listing (a record of an asset at a given time).
#
# @option params [required, String] :domain_identifier
# The ID of the Amazon DataZone domain.
#
@@ -5250,10 +5328,97 @@
def list_environments(params = {}, options = {})
req = build_request(:list_environments, params)
req.send_request(options)
end
+ # Lists the history of the specified data lineage node.
+ #
+ # @option params [String] :direction
+ # The direction of the data lineage node refers to the lineage node
+ # having neighbors in that direction. For example, if direction is
+ # `UPSTREAM`, the `ListLineageNodeHistory` API responds with historical
+ # versions with upstream neighbors only.
+ #
+ # @option params [required, String] :domain_identifier
+ # The ID of the domain where you want to list the history of the
+ # specified data lineage node.
+ #
+ # @option params [Time,DateTime,Date,Integer,String] :event_timestamp_gte
+ # Specifies whether the action is to return data lineage node history
+ # from the time after the event timestamp.
+ #
+ # @option params [Time,DateTime,Date,Integer,String] :event_timestamp_lte
+ # Specifies whether the action is to return data lineage node history
+ # from the time prior of the event timestamp.
+ #
+ # @option params [required, String] :identifier
+ # The ID of the data lineage node whose history you want to list.
+ #
+ # @option params [Integer] :max_results
+ # The maximum number of history items to return in a single call to
+ # ListLineageNodeHistory. When the number of memberships to be listed is
+ # greater than the value of MaxResults, the response contains a
+ # NextToken value that you can use in a subsequent call to
+ # ListLineageNodeHistory to list the next set of items.
+ #
+ # @option params [String] :next_token
+ # When the number of history items is greater than the default value for
+ # the MaxResults parameter, or if you explicitly specify a value for
+ # MaxResults that is less than the number of items, the response
+ # includes a pagination token named NextToken. You can specify this
+ # NextToken value in a subsequent call to ListLineageNodeHistory to list
+ # the next set of items.
+ #
+ # @option params [String] :sort_order
+ # The order by which you want data lineage node history to be sorted.
+ #
+ # @return [Types::ListLineageNodeHistoryOutput] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::ListLineageNodeHistoryOutput#next_token #next_token} => String
+ # * {Types::ListLineageNodeHistoryOutput#nodes #nodes} => Array<Types::LineageNodeSummary>
+ #
+ # The returned {Seahorse::Client::Response response} is a pageable response and is Enumerable. For details on usage see {Aws::PageableResponse PageableResponse}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.list_lineage_node_history({
+ # direction: "UPSTREAM", # accepts UPSTREAM, DOWNSTREAM
+ # domain_identifier: "DomainId", # required
+ # event_timestamp_gte: Time.now,
+ # event_timestamp_lte: Time.now,
+ # identifier: "LineageNodeIdentifier", # required
+ # max_results: 1,
+ # next_token: "PaginationToken",
+ # sort_order: "ASCENDING", # accepts ASCENDING, DESCENDING
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.next_token #=> String
+ # resp.nodes #=> Array
+ # resp.nodes[0].created_at #=> Time
+ # resp.nodes[0].created_by #=> String
+ # resp.nodes[0].description #=> String
+ # resp.nodes[0].domain_id #=> String
+ # resp.nodes[0].event_timestamp #=> Time
+ # resp.nodes[0].id #=> String
+ # resp.nodes[0].name #=> String
+ # resp.nodes[0].source_identifier #=> String
+ # resp.nodes[0].type_name #=> String
+ # resp.nodes[0].type_revision #=> String
+ # resp.nodes[0].updated_at #=> Time
+ # resp.nodes[0].updated_by #=> String
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/datazone-2018-05-10/ListLineageNodeHistory AWS API Documentation
+ #
+ # @overload list_lineage_node_history(params = {})
+ # @param [Hash] params ({})
+ def list_lineage_node_history(params = {}, options = {})
+ req = build_request(:list_lineage_node_history, params)
+ req.send_request(options)
+ end
+
# Lists all metadata generation runs.
#
# @option params [required, String] :domain_identifier
# The ID of the Amazon DataZone domain where you want to list metadata
# generation runs.
@@ -6029,10 +6194,45 @@
def list_time_series_data_points(params = {}, options = {})
req = build_request(:list_time_series_data_points, params)
req.send_request(options)
end
+ # Posts a data lineage event.
+ #
+ # @option params [String] :client_token
+ # A unique, case-sensitive identifier that is provided to ensure the
+ # idempotency of the request.
+ #
+ # **A suitable default value is auto-generated.** You should normally
+ # not need to pass this option.**
+ #
+ # @option params [required, String] :domain_identifier
+ # The ID of the domain where you want to post a data lineage event.
+ #
+ # @option params [required, String, StringIO, File] :event
+ # The data lineage event that you want to post. Only open-lineage run
+ # event are supported as events.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.post_lineage_event({
+ # client_token: "ClientToken",
+ # domain_identifier: "DomainId", # required
+ # event: "data", # required
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/datazone-2018-05-10/PostLineageEvent AWS API Documentation
+ #
+ # @overload post_lineage_event(params = {})
+ # @param [Hash] params ({})
+ def post_lineage_event(params = {}, options = {})
+ req = build_request(:post_lineage_event, params)
+ req.send_request(options)
+ end
+
# Posts time series data points to Amazon DataZone for the specified
# asset.
#
# @option params [String] :client_token
# A unique, case-sensitive identifier that is provided to ensure the
@@ -6806,11 +7006,11 @@
# search_in: [
# {
# attribute: "Attribute", # required
# },
# ],
- # search_scope: "ASSET_TYPE", # required, accepts ASSET_TYPE, FORM_TYPE
+ # search_scope: "ASSET_TYPE", # required, accepts ASSET_TYPE, FORM_TYPE, LINEAGE_NODE_TYPE
# search_text: "SearchText",
# sort: {
# attribute: "Attribute", # required
# order: "ASCENDING", # accepts ASCENDING, DESCENDING
# },
@@ -6846,10 +7046,22 @@
# resp.items[0].form_type_item.origin_domain_id #=> String
# resp.items[0].form_type_item.origin_project_id #=> String
# resp.items[0].form_type_item.owning_project_id #=> String
# resp.items[0].form_type_item.revision #=> String
# resp.items[0].form_type_item.status #=> String, one of "ENABLED", "DISABLED"
+ # resp.items[0].lineage_node_type_item.created_at #=> Time
+ # resp.items[0].lineage_node_type_item.created_by #=> String
+ # resp.items[0].lineage_node_type_item.description #=> String
+ # resp.items[0].lineage_node_type_item.domain_id #=> String
+ # resp.items[0].lineage_node_type_item.forms_output #=> Hash
+ # resp.items[0].lineage_node_type_item.forms_output["FormName"].required #=> Boolean
+ # resp.items[0].lineage_node_type_item.forms_output["FormName"].type_name #=> String
+ # resp.items[0].lineage_node_type_item.forms_output["FormName"].type_revision #=> String
+ # resp.items[0].lineage_node_type_item.name #=> String
+ # resp.items[0].lineage_node_type_item.revision #=> String
+ # resp.items[0].lineage_node_type_item.updated_at #=> Time
+ # resp.items[0].lineage_node_type_item.updated_by #=> String
# resp.next_token #=> String
# resp.total_match_count #=> Integer
#
# @see http://docs.aws.amazon.com/goto/WebAPI/datazone-2018-05-10/SearchTypes AWS API Documentation
#
@@ -8238,10 +8450,10 @@
operation: config.api.operation(operation_name),
client: self,
params: params,
config: config)
context[:gem_name] = 'aws-sdk-datazone'
- context[:gem_version] = '1.11.0'
+ context[:gem_version] = '1.12.0'
Seahorse::Client::Request.new(handlers, context)
end
# @api private
# @deprecated