org.apache.flink.table.gateway.api.endpoint

Interface SqlGatewayEndpointFactory.Context

All Known Implementing Classes:

SqlGatewayEndpointFactoryUtils.DefaultEndpointFactoryContext

Enclosing interface:

SqlGatewayEndpointFactory

@PublicEvolving
public static interface SqlGatewayEndpointFactory.Context

Provides information describing the endpoint to be accessed.

Method Summary

Modifier and Type	Method and Description
Map<String,String>	getEndpointOptions() Returns the options with which the endpoint is created.
ReadableConfig	getFlinkConfiguration() Gives read-only access to the configuration of the current session.
SqlGatewayService	getSqlGatewayService() Get the service to execute the request.

Method Detail

getSqlGatewayService

SqlGatewayService getSqlGatewayService()

Get the service to execute the request.

getFlinkConfiguration

ReadableConfig getFlinkConfiguration()

Gives read-only access to the configuration of the current session.

getEndpointOptions

Map<String,String> getEndpointOptions()

Returns the options with which the endpoint is created. All options that are prefixed with the endpoint identifier are included in the map.

All the keys in the endpoint options are pruned with the prefix. For example, the option sql-gateway.endpoint.rest.host's key is host in the map.

An implementation should perform validation of these options.