Package 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 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 Details

StringAgg

public StringAgg()