Package org.apache.flink.table.gateway.api.session

Class SessionEnvironment.Builder

java.lang.Object

org.apache.flink.table.gateway.api.session.SessionEnvironment.Builder

Enclosing class:

SessionEnvironment

@PublicEvolving
public static class SessionEnvironment.Builder
extends Object

Builder to build the SessionEnvironment.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
SessionEnvironment.Builder	addSessionConfig(Map<String,String> sessionConfig)
SessionEnvironment	build()
SessionEnvironment.Builder	registerCatalog(String catalogName, org.apache.flink.table.catalog.Catalog catalog)
SessionEnvironment.Builder	registerCatalogCreator(String catalogName, SessionEnvironment.CatalogCreator catalogCreator)
SessionEnvironment.Builder	registerModuleAtHead(String moduleName, org.apache.flink.table.module.Module module)
SessionEnvironment.Builder	registerModuleCreatorAtHead(String moduleName, SessionEnvironment.ModuleCreator moduleCreator)
SessionEnvironment.Builder	setDefaultCatalog(String defaultCatalog)
SessionEnvironment.Builder	setSessionEndpointVersion(EndpointVersion version)
SessionEnvironment.Builder	setSessionName(String sessionName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

setSessionName

public SessionEnvironment.Builder setSessionName(String sessionName)

setSessionEndpointVersion

public SessionEnvironment.Builder setSessionEndpointVersion(EndpointVersion version)

addSessionConfig

public SessionEnvironment.Builder addSessionConfig(Map<String,String> sessionConfig)

setDefaultCatalog

public SessionEnvironment.Builder setDefaultCatalog(@Nullable
                                                    String defaultCatalog)

registerCatalog

public SessionEnvironment.Builder registerCatalog(String catalogName,
                                                  org.apache.flink.table.catalog.Catalog catalog)

registerCatalogCreator

public SessionEnvironment.Builder registerCatalogCreator(String catalogName,
                                                         SessionEnvironment.CatalogCreator catalogCreator)

registerModuleAtHead

public SessionEnvironment.Builder registerModuleAtHead(String moduleName,
                                                       org.apache.flink.table.module.Module module)

registerModuleCreatorAtHead

public SessionEnvironment.Builder registerModuleCreatorAtHead(String moduleName,
                                                              SessionEnvironment.ModuleCreator moduleCreator)

build

public SessionEnvironment build()