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:

java.io.Serializable

Enclosing class:

Group.CombineFieldsByFields<InputT>

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

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
Fanout()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Fanout

public Fanout()

Method Detail

getKind

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

getNumber

public abstract java.lang.Integer getNumber()

getFunction

public abstract SerializableFunction<Row,java.lang.Integer> getFunction()

of

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

of

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