Package org.apache.flink.cdc.udf.examples.java

Class ThrottlerFunctionClass

java.lang.Object

org.apache.flink.cdc.udf.examples.java.ThrottlerFunctionClass

All Implemented Interfaces:

UserDefinedFunction

public class ThrottlerFunctionClass
extends Object
implements UserDefinedFunction

This is an example UDF class for slowing down the pipeline deliberately.

Constructor Summary

Constructors

Constructor	Description
ThrottlerFunctionClass()

Method Summary

Modifier and Type	Method	Description
String	eval(Object o, int seconds)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.cdc.common.udf.UserDefinedFunction

close, getReturnType, getReturnType, open, open

Constructor Detail

ThrottlerFunctionClass

public ThrottlerFunctionClass()

Method Detail

eval

public String eval(Object o,
                   int seconds)