Package org.apache.beam.sdk.extensions.sql.udf

Class ScalarFn

java.lang.Object

org.apache.beam.sdk.extensions.sql.udf.ScalarFn

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

UdfTestProvider.DateIncrementAllFn, UdfTestProvider.HelloWorldFn, UdfTestProvider.IncrementFn, UdfTestProvider.IsNullFn, UdfTestProvider.MatchFn, UdfTestProvider.UnusedFn

public abstract class ScalarFn
extends Object
implements Serializable

A scalar function that can be executed as part of a SQL query. Subclasses must contain exactly one method annotated with ScalarFn.ApplyMethod, which will be applied to the SQL function arguments at runtime.

For example:

 public class IncrementFn extends ScalarFn {
  @ApplyMethod
   public Long increment(Long i) {
     return i + 1;
   }
 }
 

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static @interface	ScalarFn.ApplyMethod	Annotates the single method in a ScalarFn implementation that is to be applied to SQL function arguments.

Constructor Summary

Constructors

Constructor	Description
ScalarFn()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Details

ScalarFn

public ScalarFn()