Package org.apache.flink.table.secret

Class GenericInMemorySecretStoreFactory

java.lang.Object

org.apache.flink.table.secret.GenericInMemorySecretStoreFactory

All Implemented Interfaces:

org.apache.flink.table.factories.Factory, org.apache.flink.table.secret.SecretStoreFactory

@Internal
public class GenericInMemorySecretStoreFactory
extends Object
implements org.apache.flink.table.secret.SecretStoreFactory

Factory for creating GenericInMemorySecretStore instances.

This factory creates in-memory secret stores that are suitable for testing and development purposes. Secrets are stored in plaintext JSON format in memory and are not persisted.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.secret.SecretStoreFactory

org.apache.flink.table.secret.SecretStoreFactory.Context

Field Summary

Fields

Modifier and Type	Field	Description
static String	IDENTIFIER

Constructor Summary

Constructors

Constructor	Description
GenericInMemorySecretStoreFactory()

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.flink.table.secret.SecretStore	createSecretStore()
String	factoryIdentifier()
void	open(org.apache.flink.table.secret.SecretStoreFactory.Context context)
Set<org.apache.flink.configuration.ConfigOption<?>>	optionalOptions()
Set<org.apache.flink.configuration.ConfigOption<?>>	requiredOptions()

Methods inherited from class java.lang.Object

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

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

Constructor Detail

GenericInMemorySecretStoreFactory

public GenericInMemorySecretStoreFactory()

Method Detail

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

createSecretStore

public org.apache.flink.table.secret.SecretStore createSecretStore()

Specified by:

createSecretStore in interface org.apache.flink.table.secret.SecretStoreFactory

open

public void open(org.apache.flink.table.secret.SecretStoreFactory.Context context)

Specified by:

open in interface org.apache.flink.table.secret.SecretStoreFactory

close

public void close()
           throws org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

close in interface org.apache.flink.table.secret.SecretStoreFactory

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException