public static class PubSubSource.DeserializationSchemaBuilder extends Object
PubSubSource.PubSubSourceBuilder
to set required fields.Constructor and Description |
---|
DeserializationSchemaBuilder() |
Modifier and Type | Method and Description |
---|---|
<OUT> PubSubSource.ProjectNameBuilder<OUT> |
withDeserializationSchema(DeserializationSchema<OUT> deserializationSchema)
Set the DeserializationSchema used to deserialize incoming PubSubMessages.
|
<OUT> PubSubSource.ProjectNameBuilder<OUT> |
withDeserializationSchema(PubSubDeserializationSchema<OUT> deserializationSchema)
Set the DeserializationSchema used to deserialize incoming PubSubMessages.
|
public <OUT> PubSubSource.ProjectNameBuilder<OUT> withDeserializationSchema(DeserializationSchema<OUT> deserializationSchema)
PubSubDeserializationSchema
) method instead.public <OUT> PubSubSource.ProjectNameBuilder<OUT> withDeserializationSchema(PubSubDeserializationSchema<OUT> deserializationSchema)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.