Demonstrates how to snapshot the state of a streaming job.
require "google/cloud/dataflow/v1beta3" # Create a client object. The client can be reused for multiple calls. client = Google::Cloud::Dataflow::V1beta3::Jobs::Client.new # Create a request. To set request fields, pass in keyword arguments. request = Google::Cloud::Dataflow::V1beta3::SnapshotJobRequest.new # Call the snapshot_job method. result = client.snapshot_job request # The returned object is of type Google::Cloud::Dataflow::V1beta3::Snapshot. p result
To search and filter code samples for other Google Cloud products, see the Google Cloud sample browser.