Class SqlGatewayRestEndpointFactory

  • All Implemented Interfaces:
    org.apache.flink.table.factories.Factory, org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactory

    public class SqlGatewayRestEndpointFactory
    extends Object
    implements org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactory
    The factory for sql gateway.
    • Constructor Detail

      • SqlGatewayRestEndpointFactory

        public SqlGatewayRestEndpointFactory()
    • Method Detail

      • createSqlGatewayEndpoint

        public org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpoint createSqlGatewayEndpoint​(org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactory.Context context)
        Specified by:
        createSqlGatewayEndpoint in interface org.apache.flink.table.gateway.api.endpoint.SqlGatewayEndpointFactory
      • rebuildRestEndpointOptions

        public static org.apache.flink.configuration.Configuration rebuildRestEndpointOptions​(Map<String,​String> configMap)
      • factoryIdentifier

        public String factoryIdentifier()
        Specified by:
        factoryIdentifier in interface org.apache.flink.table.factories.Factory
      • requiredOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
        Specified by:
        requiredOptions in interface org.apache.flink.table.factories.Factory
      • optionalOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
        Specified by:
        optionalOptions in interface org.apache.flink.table.factories.Factory