BlobStreamInputDataSource Class

public final class BlobStreamInputDataSource
extends StreamInputDataSource

Describes a blob input data source that contains stream data.

Constructor Summary

Constructor Description
BlobStreamInputDataSource()

Creates an instance of BlobStreamInputDataSource class.

Method Summary

Modifier and Type Method and Description
AuthenticationMode authenticationMode()

Get the authenticationMode property: Authentication Mode.

String container()

Get the container property: The name of a container within the associated Storage account.

String dateFormat()

Get the dateFormat property: The date format.

static BlobStreamInputDataSource fromJson(JsonReader jsonReader)

Reads an instance of BlobStreamInputDataSource from the JsonReader.

String pathPattern()

Get the pathPattern property: The blob path pattern.

Integer sourcePartitionCount()

Get the sourcePartitionCount property: The partition count of the blob input data source.

List<StorageAccount> storageAccounts()

Get the storageAccounts property: A list of one or more Azure Storage accounts.

String timeFormat()

Get the timeFormat property: The time format.

JsonWriter toJson(JsonWriter jsonWriter)
String type()

Get the type property: Indicates the type of input data source containing stream data.

void validate()

Validates the instance.

BlobStreamInputDataSource withAuthenticationMode(AuthenticationMode authenticationMode)

Set the authenticationMode property: Authentication Mode.

BlobStreamInputDataSource withContainer(String container)

Set the container property: The name of a container within the associated Storage account.

BlobStreamInputDataSource withDateFormat(String dateFormat)

Set the dateFormat property: The date format.

BlobStreamInputDataSource withPathPattern(String pathPattern)

Set the pathPattern property: The blob path pattern.

BlobStreamInputDataSource withSourcePartitionCount(Integer sourcePartitionCount)

Set the sourcePartitionCount property: The partition count of the blob input data source.

BlobStreamInputDataSource withStorageAccounts(List<StorageAccount> storageAccounts)

Set the storageAccounts property: A list of one or more Azure Storage accounts.

BlobStreamInputDataSource withTimeFormat(String timeFormat)

Set the timeFormat property: The time format.

Methods inherited from StreamInputDataSource

Methods inherited from java.lang.Object

Constructor Details

BlobStreamInputDataSource

public BlobStreamInputDataSource()

Creates an instance of BlobStreamInputDataSource class.

Method Details

authenticationMode

public AuthenticationMode authenticationMode()

Get the authenticationMode property: Authentication Mode.

Returns:

the authenticationMode value.

container

public String container()

Get the container property: The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.

Returns:

the container value.

dateFormat

public String dateFormat()

Get the dateFormat property: The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

Returns:

the dateFormat value.

fromJson

public static BlobStreamInputDataSource fromJson(JsonReader jsonReader)

Reads an instance of BlobStreamInputDataSource from the JsonReader.

Parameters:

jsonReader - The JsonReader being read.

Returns:

An instance of BlobStreamInputDataSource if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.

Throws:

IOException

- If an error occurs while reading the BlobStreamInputDataSource.

pathPattern

public String pathPattern()

Get the pathPattern property: The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input or https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.

Returns:

the pathPattern value.

sourcePartitionCount

public Integer sourcePartitionCount()

Get the sourcePartitionCount property: The partition count of the blob input data source. Range 1 - 1024.

Returns:

the sourcePartitionCount value.

storageAccounts

public List<StorageAccount> storageAccounts()

Get the storageAccounts property: A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.

Returns:

the storageAccounts value.

timeFormat

public String timeFormat()

Get the timeFormat property: The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

Returns:

the timeFormat value.

toJson

public JsonWriter toJson(JsonWriter jsonWriter)

Overrides:

BlobStreamInputDataSource.toJson(JsonWriter jsonWriter)

Parameters:

jsonWriter

Throws:

type

public String type()

Get the type property: Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.

Overrides:

BlobStreamInputDataSource.type()

Returns:

the type value.

validate

public void validate()

Validates the instance.

Overrides:

BlobStreamInputDataSource.validate()

withAuthenticationMode

public BlobStreamInputDataSource withAuthenticationMode(AuthenticationMode authenticationMode)

Set the authenticationMode property: Authentication Mode.

Parameters:

authenticationMode - the authenticationMode value to set.

Returns:

the BlobStreamInputDataSource object itself.

withContainer

public BlobStreamInputDataSource withContainer(String container)

Set the container property: The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.

Parameters:

container - the container value to set.

Returns:

the BlobStreamInputDataSource object itself.

withDateFormat

public BlobStreamInputDataSource withDateFormat(String dateFormat)

Set the dateFormat property: The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

Parameters:

dateFormat - the dateFormat value to set.

Returns:

the BlobStreamInputDataSource object itself.

withPathPattern

public BlobStreamInputDataSource withPathPattern(String pathPattern)

Set the pathPattern property: The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input or https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.

Parameters:

pathPattern - the pathPattern value to set.

Returns:

the BlobStreamInputDataSource object itself.

withSourcePartitionCount

public BlobStreamInputDataSource withSourcePartitionCount(Integer sourcePartitionCount)

Set the sourcePartitionCount property: The partition count of the blob input data source. Range 1 - 1024.

Parameters:

sourcePartitionCount - the sourcePartitionCount value to set.

Returns:

the BlobStreamInputDataSource object itself.

withStorageAccounts

public BlobStreamInputDataSource withStorageAccounts(List<StorageAccount> storageAccounts)

Set the storageAccounts property: A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.

Parameters:

storageAccounts - the storageAccounts value to set.

Returns:

the BlobStreamInputDataSource object itself.

withTimeFormat

public BlobStreamInputDataSource withTimeFormat(String timeFormat)

Set the timeFormat property: The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

Parameters:

timeFormat - the timeFormat value to set.

Returns:

the BlobStreamInputDataSource object itself.

Applies to