Uses of Class
io.confluent.flink.plugin.ConfluentSettings.Builder
Packages that use ConfluentSettings.Builder
-
Uses of ConfluentSettings.Builder in io.confluent.flink.plugin
Methods in io.confluent.flink.plugin that return ConfluentSettings.BuilderModifier and TypeMethodDescriptionApplies configuration from CLI arguments on top of the current builder state.static ConfluentSettings.BuilderConfluentSettings.newBuilder()Creates a builder for Confluent-specificEnvironmentSettings.static ConfluentSettings.BuilderConfluentSettings.newBuilderFromArgs(String[] args) Creates a builder for Confluent-specificEnvironmentSettings.static ConfluentSettings.BuilderConfluentSettings.newBuilderFromFile(File file) Creates a builder for Confluent-specificEnvironmentSettings.static ConfluentSettings.BuilderConfluentSettings.newBuilderFromFile(String filePath) Creates a builder for Confluent-specificEnvironmentSettings.static ConfluentSettings.BuilderConfluentSettings.newBuilderFromResource(String resourcePath) Creates a builder for Confluent-specificEnvironmentSettings.ConfluentSettings.Builder.setApplicationName(String name) Sets a name for this Table API application.ConfluentSettings.Builder.setArtifactApiKey(String key) Sets the API key for Artifacts creation.ConfluentSettings.Builder.setArtifactApiSecret(String secret) Sets the API secret for Artifacts creation.ConfluentSettings.Builder.setArtifactEndpointTemplate(String artifactEndpointTemplate) Sets the template for the artifact endpoint URL.ConfluentSettings.Builder.setAuthMode(AuthMode authMode) Sets the authentication mode for the Confluent Cloud REST APIs.ConfluentSettings.Builder.setCatalogCache(Duration expiration) Sets the expiration time for catalog objects before Confluent Cloud is called again.Sets the Confluent identifier for a cloud provider.ConfluentSettings.Builder.setComputePoolId(String computePoolId) Sets the ID of the compute pool.ConfluentSettings.Builder.setEndpointTemplate(String endpointTemplate) Sets the template for the endpoint URL.ConfluentSettings.Builder.setEnvironmentId(String envId) Sets the ID of the environment.ConfluentSettings.Builder.setFlinkApiKey(String key) Sets the API key for Flink access.ConfluentSettings.Builder.setFlinkApiSecret(String secret) Sets the API secret for Flink access.ConfluentSettings.Builder.setGlobalApiKey(String key) Sets the global API key used for both Flink and Artifact access.ConfluentSettings.Builder.setGlobalApiSecret(String secret) Sets the global API secret used for both Flink and Artifact access.ConfluentSettings.Builder.setHttpUserAgent(String userAgent) Sets the HTTP User-Agent for API requests.ConfluentSettings.Builder.setOAuthExternalAccessToken(String accessToken) Sets a pre-issued OAuth bearer token.ConfluentSettings.Builder.setOAuthExternalClientId(String clientId) Sets the client ID registered with the external IdP.ConfluentSettings.Builder.setOAuthExternalClientSecret(String clientSecret) Sets the client secret registered with the external IdP.ConfluentSettings.Builder.setOAuthExternalTokenScope(String scope) Sets the OAuth scope to request from the IdP.ConfluentSettings.Builder.setOAuthExternalTokenUrl(String tokenUrl) Sets the URL of the external IdP's OAuth 2.0 token endpoint.ConfluentSettings.Builder.setOAuthIdentityPoolId(String identityPoolId) Sets the Confluent Cloud identity pool ID.ConfluentSettings.Builder.setOAuthTokenProvider(OAuthTokenProvider provider) Registers a programmatic OAuth token provider for cloud-native identity flows (Azure Managed Identity, AWS IAM workload identity, custom token services).ConfluentSettings.Builder.setOnConflict(OnConflictMode mode) Sets the behavior when a statement could not be updated, due to a conflict.Sets a Confluent-specific configuration option.ConfluentSettings.Builder.setOrganizationId(String orgId) Sets the ID of the organization.ConfluentSettings.Builder.setPrincipalId(String principalId) Sets the Principal that runs submitted statements.Sets the Confluent identifier for a cloud provider's region.ConfluentSettings.Builder.setRestEndpoint(String endpoint) Sets the URL to the REST endpoint.ConfluentSettings.Builder.setStatementName(String name) Sets the statement name for statement submission.ConfluentSettings.Builder.setTemporaryDirectory(String dir) Sets the directory for temporary files, e.g.