def create_or_replace_with_http_info(input, resource_group_name, job_name, input_name, if_match:nil, if_none_match:nil, custom_headers:nil)
      create_or_replace_async(input, resource_group_name, job_name, input_name, if_match:if_match, if_none_match:if_none_match, custom_headers:custom_headers).value!
    end
def create_or_replace_with_http_info(input, resource_group_name, job_name, input_name, if_match:nil, if_none_match:nil, custom_headers:nil)
      create_or_replace_async(input, resource_group_name, job_name, input_name, if_match:if_match, if_none_match:if_none_match, custom_headers:custom_headers).value!
    end
Creates an input or replaces an already existing input under an existing
 streaming job.

 @param input [Input] The definition of the input that will be used to create
 a new input or replace the existing one under the streaming job.
 @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 input_name [String] The name of the input.
 @param if_match [String] The ETag of the input. Omit this value to always
 overwrite the current input. Specify the last-seen ETag value to prevent
 accidentally overwritting concurrent changes.
 @param if_none_match [String] Set to '*' to allow a new input to be created,
 but to prevent updating an existing input. 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 [MsRestAzure::AzureOperationResponse] HTTP response information.