def create_or_replace(streaming_job, resource_group_name, job_name, if_match:nil, if_none_match:nil, custom_headers:nil)
      response = create_or_replace_async(streaming_job, resource_group_name, job_name, if_match:if_match, if_none_match:if_none_match, custom_headers:custom_headers).value!
      response.body unless response.nil?
    end
def create_or_replace(streaming_job, resource_group_name, job_name, if_match:nil, if_none_match:nil, custom_headers:nil)
      response = create_or_replace_async(streaming_job, resource_group_name, job_name, if_match:if_match, if_none_match:if_none_match, custom_headers:custom_headers).value!
      response.body unless response.nil?
    end
Creates a streaming job or replaces an already existing streaming job.

 @param streaming_job [StreamingJob] The definition of the streaming job that
 will be used to create a new streaming job or replace the existing one.
 @param resource_group_name [String] The name of the resource group that
 contains the resource. You can obtain this value from the Azure Resource
 Manager API or the portal.
 @param job_name [String] The name of the streaming job.
 @param if_match [String] The ETag of the streaming job. Omit this value to
 always overwrite the current record set. Specify the last-seen ETag value to
 prevent accidentally overwritting concurrent changes.
 @param if_none_match [String] Set to '*' to allow a new streaming job to be
 created, but to prevent updating an existing record set. Other values will
 result in a 412 Pre-condition Failed response.
 @param custom_headers [Hash{String => String}] A hash of custom headers that
 will be added to the HTTP request.

 @return [StreamingJob] operation results.