Hello All,
The data source for our Beam pipleline is in S3 bucket, Is
there any built-in I/O Connector available with Java samples? If so, can you
please guide me how to integrate with them?.
I am using Bean SDK for Java version 2.4.0 and Spark runner in
clustered deployment.
<dependency>
<groupId>org.apache.beam</groupId>
<artifactId>beam-sdks-java-core</artifactId>
<version>2.4.0</version>
</dependency>
Cheers,
S. Sahayaraj
