Package org.apache.beam.sdk.schemas.transforms

Class Group.CombineFieldsByFields.Fanout

java.lang.Object

org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields.Fanout

All Implemented Interfaces:

Serializable

Enclosing class:

Group.CombineFieldsByFields<InputT>

public abstract static class Group.CombineFieldsByFields.Fanout
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Group.CombineFieldsByFields.Fanout.Kind

Constructor Summary

Constructors

Constructor	Description
Fanout()

Method Summary

Modifier and Type	Method	Description
abstract SerializableFunction<Row,Integer>	getFunction()
abstract Group.CombineFieldsByFields.Fanout.Kind	getKind()
abstract Integer	getNumber()
static Group.CombineFieldsByFields.Fanout	of(int n)
static Group.CombineFieldsByFields.Fanout	of(SerializableFunction<Row,Integer> f)

Methods inherited from class java.lang.Object

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

Constructor Details

Fanout

public Fanout()

Method Details

getKind

public abstract Group.CombineFieldsByFields.Fanout.Kind getKind()

getNumber

public abstract Integer getNumber()

getFunction

public abstract SerializableFunction<Row,Integer> getFunction()

of

public static Group.CombineFieldsByFields.Fanout of(int n)

of

public static Group.CombineFieldsByFields.Fanout of(SerializableFunction<Row,Integer> f)