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

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

getAzureCredentialsProvider, setAzureCredentialsProvider

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

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

populateDisplayData

Method Detail

getCosmosClientBuilder

@Default.InstanceFactory(value=CosmosOptions.CosmosClientBuilderFactory.class)
com.azure.cosmos.CosmosClientBuilder getCosmosClientBuilder()

setCosmosClientBuilder

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

getCosmosServiceEndpoint

@Nullable java.lang.String getCosmosServiceEndpoint()

The Azure Cosmos service endpoint used by the Cosmos client.

setCosmosServiceEndpoint

void setCosmosServiceEndpoint(java.lang.String endpoint)

getCosmosKey

@Nullable java.lang.String getCosmosKey()

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

setCosmosKey

void setCosmosKey(java.lang.String key)