Package org.apache.flink.table.examples.java.basics

Class GettingStartedExample.AddressNormalizer

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.ScalarFunction

org.apache.flink.table.examples.java.basics.GettingStartedExample.AddressNormalizer

All Implemented Interfaces:

Serializable, FunctionDefinition

Enclosing class:

GettingStartedExample

public static class GettingStartedExample.AddressNormalizer
extends ScalarFunction

We can put frequently used procedures in user-defined functions.

It is possible to call third-party libraries here as well.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AddressNormalizer()

Method Summary

Modifier and Type	Method	Description
String	eval(String street, String zipCode, String city)

Methods inherited from class org.apache.flink.table.functions.ScalarFunction

getKind, getParameterTypes, getResultType, getTypeInference

Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction

close, functionIdentifier, open, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition

getRequirements, isDeterministic, supportsConstantFolding

Constructor Detail

AddressNormalizer

public AddressNormalizer()

Method Detail

eval

public String eval(String street,
                   String zipCode,
                   String city)