Package org.apache.beam.sdk.io.azure.options

Interface AzureOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

All Known Subinterfaces:

BlobstoreOptions, CosmosOptions

public interface AzureOptions
extends PipelineOptions

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	AzureOptions.AzureUserCredentialsFactory	Attempts to load Azure credentials.

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method	Description
com.azure.core.credential.TokenCredential	getAzureCredentialsProvider()	The credential instance that should be used to authenticate against Azure services.
void	setAzureCredentialsProvider(com.azure.core.credential.TokenCredential value)

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Method Details

getAzureCredentialsProvider

@InstanceFactory(AzureUserCredentialsFactory.class)
com.azure.core.credential.TokenCredential getAzureCredentialsProvider()

The credential instance that should be used to authenticate against Azure services. The option value must contain a "@type" field and an Azure credentials provider class as the field value.

For example, to specify the Azure client id, tenant id, and client secret, specify the following: {"@type" : "ClientSecretCredential", "azureClientId": "client_id_value", "azureTenantId": "tenant_id_value", "azureClientSecret": "client_secret_value"}

setAzureCredentialsProvider

void setAzureCredentialsProvider(com.azure.core.credential.TokenCredential value)