iht commented on code in PR #32060:
URL: https://github.com/apache/beam/pull/32060#discussion_r1755219737
##########
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/SolaceIO.java:
##########
@@ -961,6 +977,21 @@ public Write<T> withWriterType(WriterType writerType) {
return toBuilder().setWriterType(writerType).build();
}
+ /**
+ * Set the format function for your custom data type, and/or for dynamic
destinations.
+ *
+ * <p>If you are using a custom data class, this function should return a
{@link Solace.Record}
+ * corresponding to your custom data class instance.
+ *
+ * <p>If you are using this formatting function with dynamic destinations,
you must ensure that
+ * you set the right value in the destination value of the {@link
Solace.Record} messages.
+ *
+ * <p>In any other case, this format function is optional.
+ */
+ public Write<T> withFormatFunction(SerializableFunction<T, Solace.Record>
formatFunction) {
+ return toBuilder().setFormatFunction(formatFunction).build();
+ }
Review Comment:
You are right, it is a leftover from previous changes. Removing it in
upcoming commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
