-pulsario-using-apache-beam-java-sdk Regards, Phani Geeth Sent from Mail for Windows
Class MessagePrint extends DoFn{
@ProcessElement
public void processElement(ProcessContext c){
System.out.println(c.element);
System.out.println(c.element().getMessageRecord());
}}
Added this DoFn in pipeline after PulsarIO but not able to print any
message.
Regards,
Phani Geeth
On Fri, 7 Oct, 2022,
Hi,
Does the present cross Language functionality support creating custom Java
transforms and calling from python in Dataflow runner.
Use case: use existing Java IO as cross Language transform and call in
python pipeline in Dataflow runner.
Regards
Phani Geeth
ine. https://stackoverflow.com/questions/76681800/count-incoming-unbouned-messages-from-pubsub-using-apache-beam-java Thanks,Phani Geeth Sent from Mail for Windows
