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

Interface CosmosOptions

All Superinterfaces:

AzureOptions, HasDisplayData, PipelineOptions

public interface CosmosOptions
extends AzureOptions

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	CosmosOptions.CosmosClientBuilderFactory	Create a cosmos client from the pipeline options.

Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.azure.options.AzureOptions

AzureOptions.AzureUserCredentialsFactory

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.cosmos.CosmosClientBuilder	getCosmosClientBuilder()
@Nullable String	getCosmosKey()	The Azure Cosmos key used to perform authentication for accessing resource.
@Nullable String	getCosmosServiceEndpoint()	The Azure Cosmos service endpoint used by the Cosmos client.
void	setCosmosClientBuilder(com.azure.cosmos.CosmosClientBuilder builder)
void	setCosmosKey(String key)
void	setCosmosServiceEndpoint(String endpoint)

Methods inherited from interface org.apache.beam.sdk.io.azure.options.AzureOptions

getAzureCredentialsProvider, setAzureCredentialsProvider

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

getCosmosClientBuilder

@InstanceFactory(CosmosClientBuilderFactory.class)
com.azure.cosmos.CosmosClientBuilder getCosmosClientBuilder()

setCosmosClientBuilder

void setCosmosClientBuilder(com.azure.cosmos.CosmosClientBuilder builder)

getCosmosServiceEndpoint

@Nullable String getCosmosServiceEndpoint()

The Azure Cosmos service endpoint used by the Cosmos client.

setCosmosServiceEndpoint

void setCosmosServiceEndpoint(String endpoint)

getCosmosKey

@Nullable String getCosmosKey()

The Azure Cosmos key used to perform authentication for accessing resource.

setCosmosKey

void setCosmosKey(String key)