@Experimental(value=SCHEMAS) public class ProtoDynamicMessageSchema<T> extends java.lang.Object implements java.io.Serializable
Modifier and Type | Field and Description |
---|---|
static long |
serialVersionUID |
Modifier and Type | Method and Description |
---|---|
static ProtoDynamicMessageSchema<DynamicMessage> |
forDescriptor(ProtoDomain domain,
Descriptors.Descriptor descriptor)
Create a new ProtoDynamicMessageSchema from a
ProtoDomain and for a descriptor. |
static ProtoDynamicMessageSchema |
forDescriptor(ProtoDomain domain,
java.lang.String messageName)
Create a new ProtoDynamicMessageSchema from a
ProtoDomain and for a message. |
SerializableFunction<Row,T> |
getFromRowFunction() |
Schema |
getSchema() |
SerializableFunction<T,Row> |
getToRowFunction() |
public static final long serialVersionUID
public static ProtoDynamicMessageSchema forDescriptor(ProtoDomain domain, java.lang.String messageName)
ProtoDomain
and for a message. The
message need to be in the domain and needs to be the fully qualified name.public static ProtoDynamicMessageSchema<DynamicMessage> forDescriptor(ProtoDomain domain, Descriptors.Descriptor descriptor)
ProtoDomain
and for a descriptor. The
descriptor is only used for it's name, that name will be used for a search in the domain.public Schema getSchema()
public SerializableFunction<T,Row> getToRowFunction()
public SerializableFunction<Row,T> getFromRowFunction()