org.apache.beam.sdk.extensions.sql

Interface BeamSqlUdf

All Superinterfaces:

java.io.Serializable

@Experimental
public interface BeamSqlUdf
extends java.io.Serializable

Interface to create a UDF in Beam SQL.

A static method eval is required. Here is an example:

 public static class MyLeftFunction {
   public String eval(
       @Parameter(name = "s") String s,
       @Parameter(name = "n", optional = true) Integer n) {
     return s.substring(0, n == null ? 1 : n);
   }
 }

The first parameter is named "s" and is mandatory, and the second parameter is named "n" and is optional.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	UDF_METHOD

Field Detail

UDF_METHOD

static final java.lang.String UDF_METHOD

See Also:

Constant Field Values