Hi Folks,

I came to a situation where I need to use some values from side inputs inside a 
class which extends PTransform.  At the end I want to create 
DataSourceConfiguration object which takes values like hostname, user name and 
password(these values are coming from Vault and I want to provide them as side 
input to the method that will create DataSourceConfiguration object). And  the 
object will be passed to JdbcIO write method like mentioned here 
https://beam.apache.org/releases/javadoc/2.0.0/org/apache/beam/sdk/io/jdbc/JdbcIO.html.

But since the JdbcIO does not provide any method that accepts 'Contextful.fn', 
I am not able to pass the side inputs.

Any pointer on how this can be done will be much appreciated!

Thanks in Advance.

Thanks and Regards,
Rahul



C2 General

Reply via email to