Interface SqlGatewayEndpointFactory.Context

    • Method Detail

      • getSqlGatewayService

        SqlGatewayService getSqlGatewayService()
        Get the service to execute the request.
      • getFlinkConfiguration

        org.apache.flink.configuration.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.