Package org.apache.beam.sdk.extensions.sql.impl.udaf

Class StringAgg

  • public class StringAgg
extends java.lang.Object
    Combine.CombineFns for aggregating strings or bytes with an optional delimiter (default comma).

    StringAgg.StringAggString does not support NULL values.

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      static class  StringAgg.StringAggByte
      A Combine.CombineFn that aggregates bytes with a byte array as delimiter.
      static class  StringAgg.StringAggString
      A Combine.CombineFn that aggregates strings with a string as delimiter.

    • Constructor Summary

      Constructors 
      Constructor Description
      StringAgg()  

    • Method Summary

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • StringAgg

        public StringAgg()