Package org.apache.beam.sdk.extensions.protobuf

Class ProtoDomain

java.lang.Object

org.apache.beam.sdk.extensions.protobuf.ProtoDomain

All Implemented Interfaces:

Serializable

public final class ProtoDomain
extends Object
implements Serializable

ProtoDomain is a container class for Protobuf descriptors. By using a domain for all descriptors that are related to each other the FileDescriptorSet needs to be serialized only once in the graph.

Using a domain also grantees that all Descriptors have object equality, just like statically compiled Proto classes Descriptors. A lot of Java code isn't used to the new DynamicMessages an assume always Object equality. Because of this the domain class is immutable.

ProtoDomains aren't assumed to be used on with normal Message descriptors, only with DynamicMessage descriptors.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final long	serialVersionUID

Method Summary

Modifier and Type	Method	Description
static ProtoDomain	buildFrom(DescriptorProtos.FileDescriptorSet fileDescriptorSet)
static ProtoDomain	buildFrom(Descriptors.Descriptor descriptor)
static ProtoDomain	buildFrom(Descriptors.FileDescriptor fileDescriptor)
static ProtoDomain	buildFrom(InputStream inputStream)
boolean	contains(Descriptors.Descriptor descriptor)
boolean	equals(@Nullable Object o)
Descriptors.Descriptor	getDescriptor(String fullName)
Descriptors.FieldDescriptor	getFieldOptionById(int id)
Descriptors.FileDescriptor	getFileDescriptor(String name)
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Details

serialVersionUID

public static final long serialVersionUID

See Also:

• Constant Field Values

Method Details

buildFrom

public static ProtoDomain buildFrom(Descriptors.Descriptor descriptor)

buildFrom

public static ProtoDomain buildFrom(DescriptorProtos.FileDescriptorSet fileDescriptorSet)

buildFrom

public static ProtoDomain buildFrom(Descriptors.FileDescriptor fileDescriptor)

buildFrom

public static ProtoDomain buildFrom(InputStream inputStream)
                             throws IOException

Throws:

IOException

getFileDescriptor

public Descriptors.FileDescriptor getFileDescriptor(String name)

getDescriptor

public Descriptors.Descriptor getDescriptor(String fullName)

getFieldOptionById

public Descriptors.FieldDescriptor getFieldOptionById(int id)

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

contains

public boolean contains(Descriptors.Descriptor descriptor)