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

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

Provides interfaces for defining user-defined functions in Beam SQL.

The contents of this package are experimental. (They are not marked invalid input: '{@code as usual because that would require a dependency on the {@code :sdks:java:core} module, which we want to avoid.)'

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql	BeamSQL provides a new interface to run a SQL statement with Beam.

Class	Description
AggregateFn<InputT extends @Nullable Object,AccumT extends @Nullable Object,OutputT extends @Nullable Object>	An aggregate function that can be executed as part of a SQL query.
ScalarFn	A scalar function that can be executed as part of a SQL query.
ScalarFn.ApplyMethod	Annotates the single method in a ScalarFn implementation that is to be applied to SQL function arguments.
UdfProvider	Provider for user-defined functions written in Java.