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

Class StringAgg

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.udaf.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 and 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 and 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()