Package org.apache.beam.sdk.extensions.sql.meta.provider

Interface UdfUdafProvider

  • public interface UdfUdafProvider
    Provider for UDF and UDAF.

    • Method Summary

      All Methods Instance Methods Default Methods 
      Modifier and Type Method Description
      default java.util.Map<java.lang.String,​java.lang.Class<? extends BeamSqlUdf>> getBeamSqlUdfs()
      For UDFs implement BeamSqlUdf.
      default java.util.Map<java.lang.String,​org.apache.beam.sdk.transforms.SerializableFunction<?,​?>> getSerializableFunctionUdfs()
      For UDFs implement SerializableFunction.
      default java.util.Map<java.lang.String,​org.apache.beam.sdk.transforms.Combine.CombineFn> getUdafs()  

    • Method Detail

      • getBeamSqlUdfs

        default java.util.Map<java.lang.String,​java.lang.Class<? extends BeamSqlUdf>> getBeamSqlUdfs()
        For UDFs implement BeamSqlUdf.

      • getSerializableFunctionUdfs

        default java.util.Map<java.lang.String,​org.apache.beam.sdk.transforms.SerializableFunction<?,​?>> getSerializableFunctionUdfs()
        For UDFs implement SerializableFunction.

      • getUdafs

        default java.util.Map<java.lang.String,​org.apache.beam.sdk.transforms.Combine.CombineFn> getUdafs()