org.apache.flink.kubernetes.kubeclient.decorators

Class Decorator<R,T extends KubernetesResource<R>>

java.lang.Object

org.apache.flink.kubernetes.kubeclient.decorators.Decorator<R,T>

Direct Known Subclasses:

ConfigMapDecorator, FlinkMasterDeploymentDecorator, InitializerDecorator, OwnerReferenceDecorator, ServiceDecorator, TaskManagerPodDecorator

public abstract class Decorator<R,T extends KubernetesResource<R>>
extends Object

Abstract decorator for add features to resource such as deployment/pod/service.

Constructor Summary

Constructors

Constructor and Description
Decorator()

Method Summary

Modifier and Type	Method and Description
T	decorate(T resource) Extract real resource from resource, decorate and put it back.
protected abstract R	decorateInternalResource(R resource, Configuration flinkConfig) Decorate the internal resource.

Methods inherited from class java.lang.Object

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

Constructor Detail

Decorator

public Decorator()

Method Detail

decorateInternalResource

protected abstract R decorateInternalResource(R resource,
                                              Configuration flinkConfig)

Decorate the internal resource.

decorate

public T decorate(T resource)

Extract real resource from resource, decorate and put it back.