org.apache.flink.statefun.flink.io.kafka.binders.egress.v1

Class Module

java.lang.Object

org.apache.flink.statefun.flink.io.kafka.binders.egress.v1.Module

All Implemented Interfaces:

ExtensionModule

@AutoService(value=ExtensionModule.class)
public final class Module
extends java.lang.Object
implements ExtensionModule

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.statefun.extensions.ExtensionModule

ExtensionModule.Binder

Constructor Summary

Constructors

Constructor and Description
Module()

Method Summary

Modifier and Type	Method and Description
void	configure(java.util.Map<java.lang.String,java.lang.String> globalConfigurations, ExtensionModule.Binder universeBinder) This method binds multiple extension objects to the Stateful Functions application.

Methods inherited from class java.lang.Object

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

Constructor Detail

Module

public Module()

Method Detail

configure

public void configure(java.util.Map<java.lang.String,java.lang.String> globalConfigurations,
                      ExtensionModule.Binder universeBinder)

Description copied from interface: ExtensionModule

This method binds multiple extension objects to the Stateful Functions application.

Specified by:

configure in interface ExtensionModule

Parameters:

globalConfigurations - global configuration of the Stateful Functions application.

universeBinder - binder for binding extensions.