Skip to content

Instantly share code, notes, and snippets.

@aromanenko-dev
Last active April 29, 2021 10:37
Show Gist options
  • Save aromanenko-dev/389e2b3380daa85af7ddea289d38d7e8 to your computer and use it in GitHub Desktop.
Save aromanenko-dev/389e2b3380daa85af7ddea289d38d7e8 to your computer and use it in GitHub Desktop.
diff --git a/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java b/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
index 79648cc12e..4a19e26bee 100644
--- a/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
+++ b/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
@@ -156,11 +156,11 @@ import org.slf4j.LoggerFactory;
* case you should look into sharing a single instance of a {@link PoolingDataSource} across all the
* execution threads. For example:
*
- * <pre>{@code
- * private static class MyDataSourceProviderFn implements SerializableFunction<Void, DataSource> {
+ * <pre><code>
+ * private static class MyDataSourceProviderFn implements{@literal SerializableFunction<Void, DataSource>} {
* private static transient DataSource dataSource;
*
- * @Override
+ * {@literal @Override}
* public synchronized DataSource apply(Void input) {
* if (dataSource == null) {
* dataSource = ... build data source ...
@@ -168,12 +168,12 @@ import org.slf4j.LoggerFactory;
* return dataSource;
* }
* }
- *
+ * {@literal
* pipeline.apply(JdbcIO.<KV<Integer, String>>read()
* .withDataSourceProviderFn(new MyDataSourceProviderFn())
* // ...
* );
- * }</pre>
+ * }</code></pre>
*
* <h3>Writing to JDBC datasource</h3>
*
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment