Updates

Author: clun

README.md

@@ -23,14 +23,17 @@ To use this SDK, add the following dependency to your project:
 Documentation is avalailable in [Awesome Astra](https://awesome-astra.github.io/docs/pages/tools/integration/apache-beam-google-dataflow/) with sample codes
 
 
-- Read Data From Astra
+- **Read Data From Astra**
 
 ```java
+// LanguageCode is a sample Pojo
 
- // LanguageCode is a sample Pojo
+// LanguageCodeDaoMapperFactoryFn implements 
+// SerializableFunction<CqlSession, AstraDbMapper<LanguageCode>>
 
- // LanguageCodeDaoMapperFactoryFn implements 
- // SerializableFunction<CqlSession, AstraDbMapper<LanguageCode>>
+// Get binary from File path
+byte[] scbZip = AstraSecureConnectBundleUtils
+                .loadFromFilePath(options.getAstraSecureConnectBundle());
 
 AstraDbIO.Read<LanguageCode> read = AstraDbIO.<LanguageCode>read()
   .withToken(options.getAstraToken())

release.properties

@@ -0,0 +1,11 @@
+#release configuration
+#Mon Jun 26 14:51:31 CEST 2023
+projectVersionPolicyId=default
+scm.tagNameFormat=@{project.version}
+remoteTagging=true
+scm.commentPrefix=[maven-release-plugin] 
+pushChanges=true
+completedPhase=check-poms
+scm.url=scm\:git\:[email protected]\:clun/beam-sdks-java-io-astra.git
+exec.snapshotReleasePluginAllowed=false
+preparationGoals=clean verify

src/main/java/org/apache/beam/sdk/io/astra/db/CqlSessionHolder.java

@@ -169,18 +169,18 @@ private static synchronized void init() {
       } catch (NoSuchAlgorithmException e) {
         throw new IllegalStateException("SHA-1 is not supported");
       }
-      // Add a Shutdown Hook to close all sessions.
-      Runtime.getRuntime().addShutdownHook(new Thread(() -> { cleanup(); }));
     }
   }
 
   /**
    * Close all sessions.
    */
   public static void cleanup() {
-    cacheSessions.values().stream()
-            .filter(s->!s.isClosed())
-            .forEach(CqlSession::close);
+    if (cacheSessions != null) {
+      cacheSessions.values().stream()
+              .filter(s -> !s.isClosed())
+              .forEach(CqlSession::close);
+    }
   }
 
 }