Package co.decodable.sdk.pipeline

Class EnvironmentAccess

java.lang.Object

co.decodable.sdk.pipeline.EnvironmentAccess

public class EnvironmentAccess
extends Object

Provides access to the environment from within a custom Flink job. By default, the system environment is exposed. For testing purposes, a custom environment can be set.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	EnvironmentAccess.Environment	Exposes the environment variables of the current process.

Method Summary

Modifier and Type	Method	Description
static EnvironmentAccess.Environment	getEnvironment()	Returns the current environment.
static void	resetEnvironment()	Resets active the environment to the system environment.
static void	setEnvironment(EnvironmentAccess.Environment environment)	Sets the given environment as the active one.

Methods inherited from class java.lang.Object

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

Method Details

setEnvironment

public static void setEnvironment(EnvironmentAccess.Environment environment)

Sets the given environment as the active one.

resetEnvironment

public static void resetEnvironment()

Resets active the environment to the system environment.

getEnvironment

public static EnvironmentAccess.Environment getEnvironment()

Returns the current environment.