SessionEnvironment (Flink : 1.17-SNAPSHOT API)

@PublicEvolving
public class SessionEnvironment
extends Object

Environment to initialize the Session.

Nested Classes
Modifier and Type	Class and Description
`static class`	`SessionEnvironment.Builder` Builder to build the `SessionEnvironment`.
`static interface`	`SessionEnvironment.CatalogCreator` An interface used to create `Catalog`.
`static interface`	`SessionEnvironment.ModuleCreator` An interface used to create `Module`.

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`equals(Object o)`
`Optional<String>`	`getDefaultCatalog()`
`Map<String,SessionEnvironment.CatalogCreator>`	`getRegisteredCatalogCreators()`
`Map<String,SessionEnvironment.ModuleCreator>`	`getRegisteredModuleCreators()`
`Map<String,String>`	`getSessionConfig()`
`EndpointVersion`	`getSessionEndpointVersion()`
`Optional<String>`	`getSessionName()`
`int`	`hashCode()`
`static SessionEnvironment.Builder`	`newBuilder()`

public Optional<String> getSessionName()

public EndpointVersion getSessionEndpointVersion()

public Map<String,String> getSessionConfig()

public Map<String,SessionEnvironment.CatalogCreator> getRegisteredCatalogCreators()

public Map<String,SessionEnvironment.ModuleCreator> getRegisteredModuleCreators()

public Optional<String> getDefaultCatalog()

public static SessionEnvironment.Builder newBuilder()

Back to Flink Website