StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithCluster.withCluster(ClusterInfo cluster) |
Specifies the cluster property: The cluster which streaming jobs will run on..
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithCompatibilityLevel.withCompatibilityLevel(CompatibilityLevel compatibilityLevel) |
Specifies the compatibilityLevel property: Controls certain runtime behaviors of the streaming job..
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithContentStoragePolicy.withContentStoragePolicy(ContentStoragePolicy contentStoragePolicy) |
Specifies the contentStoragePolicy property: Valid values are JobStorageAccount and SystemAccount.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithDataLocale.withDataLocale(String dataLocale) |
Specifies the dataLocale property: The data locale of the stream analytics job.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithEventsLateArrivalMaxDelayInSeconds.withEventsLateArrivalMaxDelayInSeconds(Integer eventsLateArrivalMaxDelayInSeconds) |
Specifies the eventsLateArrivalMaxDelayInSeconds property: The maximum tolerable delay in seconds where
events arriving late could be included.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithEventsOutOfOrderMaxDelayInSeconds.withEventsOutOfOrderMaxDelayInSeconds(Integer eventsOutOfOrderMaxDelayInSeconds) |
Specifies the eventsOutOfOrderMaxDelayInSeconds property: The maximum tolerable delay in seconds where
out-of-order events can be adjusted to be back in order..
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithEventsOutOfOrderPolicy.withEventsOutOfOrderPolicy(EventsOutOfOrderPolicy eventsOutOfOrderPolicy) |
Specifies the eventsOutOfOrderPolicy property: Indicates the policy to apply to events that arrive out of
order in the input event stream..
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithResourceGroup.withExistingResourceGroup(String resourceGroupName) |
Specifies resourceGroupName.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithFunctions.withFunctions(List<FunctionInner> functions) |
Specifies the functions property: A list of one or more functions for the streaming job.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithIdentity.withIdentity(Identity identity) |
Specifies the identity property: Describes the system-assigned managed identity assigned to this job that
can be used to authenticate with inputs and outputs..
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithIfMatch.withIfMatch(String ifMatch) |
Specifies the ifMatch property: The ETag of the streaming job.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithIfNoneMatch.withIfNoneMatch(String ifNoneMatch) |
Specifies the ifNoneMatch property: Set to '*' to allow a new streaming job to be created, but to prevent
updating an existing record set.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithInputs.withInputs(List<InputInner> inputs) |
Specifies the inputs property: A list of one or more inputs to the streaming job.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithJobStorageAccount.withJobStorageAccount(JobStorageAccount jobStorageAccount) |
Specifies the jobStorageAccount property: The properties that are associated with an Azure Storage
account with MSI.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithJobType.withJobType(JobType jobType) |
Specifies the jobType property: Describes the type of the job.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithOutputErrorPolicy.withOutputErrorPolicy(OutputErrorPolicy outputErrorPolicy) |
Specifies the outputErrorPolicy property: Indicates the policy to apply to events that arrive at the
output and cannot be written to the external storage due to being malformed (missing column values,
column values of wrong type or size)..
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithOutputs.withOutputs(List<OutputInner> outputs) |
Specifies the outputs property: A list of one or more outputs for the streaming job.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithOutputStartMode.withOutputStartMode(OutputStartMode outputStartMode) |
Specifies the outputStartMode property: This property should only be utilized when it is desired that the
job be started immediately upon creation.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithOutputStartTime.withOutputStartTime(OffsetDateTime outputStartTime) |
Specifies the outputStartTime property: Value is either an ISO-8601 formatted time stamp that indicates
the starting point of the output event stream, or null to indicate that the output event stream will
start whenever the streaming job is started.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithSku.withSku(Sku sku) |
Specifies the sku property: Describes the SKU of the streaming job.
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithTags.withTags(Map<String,String> tags) |
Specifies the tags property: Resource tags..
|
StreamingJob.DefinitionStages.WithCreate |
StreamingJob.DefinitionStages.WithTransformation.withTransformation(TransformationInner transformation) |
Specifies the transformation property: Indicates the query and the number of streaming units to use for
the streaming job.
|