ListenerUtils (Flink Kubernetes: 1.9-SNAPSHOT API)

java.lang.Object
- org.apache.flink.kubernetes.operator.listener.ListenerUtils

public class ListenerUtils
extends java.lang.Object

Flink resource listener utilities.

Constructor Summary

Constructors
Constructor Description

ListenerUtils()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static java.util.Collection<FlinkResourceListener>`	`discoverListeners(FlinkConfigManager configManager)`	Load `FlinkResourceListener` implementations from the plugin directory.
`protected static java.util.Map<java.lang.String,org.apache.flink.configuration.Configuration>`	`loadListenerConfigs(org.apache.flink.configuration.Configuration configuration)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ListenerUtils
```
public ListenerUtils()
```
- Method Detail
  - discoverListeners
```
public static java.util.Collection<FlinkResourceListener> discoverListeners(FlinkConfigManager configManager)
```
    Load FlinkResourceListener implementations from the plugin directory. Only listeners that are explicitly named and configured will be enabled.
    Config format: kubernetes.operator.plugins.listeners.test.class: com.myorg.MyListener kubernetes.operator.plugins.listeners.test.k1: v1
    
    Parameters:
    
    configManager - FlinkConfigManager to access plugin configurations.
    
    Returns:
    
    Enabled listeners.
  - loadListenerConfigs
```
@VisibleForTesting
protected static java.util.Map<java.lang.String,org.apache.flink.configuration.Configuration> loadListenerConfigs(org.apache.flink.configuration.Configuration configuration)
```