diff --git a/samples/src/main/java/com/example/BearerTokenGenerationUsingThreadsExample.java b/samples/src/main/java/com/example/BearerTokenGenerationUsingThreadsExample.java
deleted file mode 100644
index 718aa21e..00000000
--- a/samples/src/main/java/com/example/BearerTokenGenerationUsingThreadsExample.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc.
-*/
-package com.example;
-
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.BearerToken;
-
-import java.io.File;
-
-public class BearerTokenGenerationUsingThreadsExample {
-    public static void main(String args[]) {
-
-        String bearerToken = null;
-
-        // Generate BearerToken with context by specifying credentials.json file path
-        try {
-            String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-            final BearerToken token = new BearerToken.BearerTokenBuilder()
-                    .setCredentials(new File(filePath))
-                    .setCtx("abc")
-                    .build();
-
-            Thread t = new Thread(new Runnable() {
-                @Override
-                public void run() {
-
-                    for (int i = 0; i < 5; i++) {
-                        try {
-                            System.out.println(token.getBearerToken());
-                        } catch (SkyflowException e) {
-                            Thread.currentThread().interrupt();
-                            throw new RuntimeException(e);
-
-                        }
-
-                    }
-                }
-            });
-
-            t.start();
-
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-
-    }
-}
diff --git a/samples/src/main/java/com/example/DeleteExample.java b/samples/src/main/java/com/example/DeleteExample.java
deleted file mode 100644
index 9ee0fc28..00000000
--- a/samples/src/main/java/com/example/DeleteExample.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
-	Copyright (c) 2023 Skyflow, Inc. 
-*/
-package com.example;
-
-import com.skyflow.entities.ResponseToken;
-import com.skyflow.entities.SkyflowConfiguration;
-import com.skyflow.entities.TokenProvider;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-
-public class DeleteExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration(
-                    "<your_vaultID>",
-                    "<your_vaultURL>",
-                    new DemoTokenProvider()
-            );
-            Skyflow skyflowClient = Skyflow.init(config);
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record = new JSONObject();
-
-            record.put("id", "<your_skyflowId>");
-            record.put("table", "<you_table_name>");
-            recordsArray.add(record);
-            JSONObject record2 = new JSONObject();
-
-            record2.put("id", "<your_skyflowId>");
-            record2.put("table", "<you_table_name>");
-            recordsArray.add(record2);
-
-            records.put("records", recordsArray);
-
-            JSONObject response = skyflowClient.delete(records);
-            System.out.println(response);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-            System.out.println("error" + e.getData());
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if (Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/DetokenizeExample.java b/samples/src/main/java/com/example/DetokenizeExample.java
deleted file mode 100644
index acc29287..00000000
--- a/samples/src/main/java/com/example/DetokenizeExample.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc. 
-*/
-package com.example;
-
-import com.skyflow.entities.RedactionType;
-import com.skyflow.entities.ResponseToken;
-import com.skyflow.entities.SkyflowConfiguration;
-import com.skyflow.entities.TokenProvider;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-
-public class DetokenizeExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration(
-                "<your_vaultID>",
-                "<your_vaultURL>", 
-                new DemoTokenProvider()
-            );
-            Skyflow skyflowClient = Skyflow.init(config);
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record1 = new JSONObject();
-            record1.put("token", "<your_token>");
-            record1.put("redaction", RedactionType.MASKED.toString());
-
-            JSONObject record2 = new JSONObject();
-            record2.put("token", "<your_token>"); // default Redaction "PLAIN_TEXT" will be applied for record2
-
-            recordsArray.add(record1);
-            recordsArray.add(record2);
-            records.put("records", recordsArray);
-
-            JSONObject response = skyflowClient.detokenize(records);
-            System.out.println(response);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-            System.out.println(e.getData());
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if(Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/GetByIdExample.java b/samples/src/main/java/com/example/GetByIdExample.java
deleted file mode 100644
index b3576fb3..00000000
--- a/samples/src/main/java/com/example/GetByIdExample.java
+++ /dev/null
@@ -1,66 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc. 
-*/
-package com.example;
-
-import com.skyflow.entities.RedactionType;
-import com.skyflow.entities.ResponseToken;
-import com.skyflow.entities.SkyflowConfiguration;
-import com.skyflow.entities.TokenProvider;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-
-public class GetByIdExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record = new JSONObject();
-            JSONArray ids = new JSONArray();
-            ids.add("<your_skyflowId>");
-
-            record.put("ids", ids);
-            record.put("table", "<you_table_name>");
-            record.put("redaction", RedactionType.PLAIN_TEXT.toString());
-            recordsArray.add(record);
-            records.put("records", recordsArray);
-
-            JSONObject response = skyflowClient.getById(records);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-            System.out.println(e.getData());
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if(Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/GetExample.java b/samples/src/main/java/com/example/GetExample.java
deleted file mode 100644
index 76cf826a..00000000
--- a/samples/src/main/java/com/example/GetExample.java
+++ /dev/null
@@ -1,74 +0,0 @@
-package com.example;
-
-import com.skyflow.entities.RedactionType;
-import com.skyflow.entities.ResponseToken;
-import com.skyflow.entities.SkyflowConfiguration;
-import com.skyflow.entities.TokenProvider;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-public class GetExample {
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject firstRecord = new JSONObject();
-
-            JSONArray ids = new JSONArray();
-            ids.add("<your_skyflowId>");
-
-            firstRecord.put("ids", ids);
-            firstRecord.put("table", "<your_table_name>");
-            firstRecord.put("redaction", RedactionType.PLAIN_TEXT.toString());
-
-            JSONObject secondRecord = new JSONObject();
-
-            JSONArray valuesArray = new JSONArray();
-            valuesArray.add("<your_column_value>");
-
-            secondRecord.put("table", "<your_table_name>");
-            secondRecord.put("columnName", "<unique_column_name>");
-            secondRecord.put("columnValues", valuesArray);
-            secondRecord.put("redaction", RedactionType.PLAIN_TEXT.toString());
-
-            recordsArray.add(firstRecord);
-            recordsArray.add(secondRecord);
-            records.put("records", recordsArray);
-
-            JSONObject response = skyflowClient.get(records);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-            System.out.println(e.getData());
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if (Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
\ No newline at end of file
diff --git a/samples/src/main/java/com/example/InsertBulkExample.java b/samples/src/main/java/com/example/InsertBulkExample.java
deleted file mode 100644
index bb191c7c..00000000
--- a/samples/src/main/java/com/example/InsertBulkExample.java
+++ /dev/null
@@ -1,58 +0,0 @@
-package com.example;
-
-import com.skyflow.entities.*;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-public class InsertBulkExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record = new JSONObject();
-            record.put("table", "<your_table_name>");
-
-            JSONObject fields = new JSONObject();
-            fields.put("<your_field_name>", "<your_field_value>");
-            record.put("fields", fields);
-            recordsArray.add(record);
-            records.put("records", recordsArray);
-
-            JSONObject res = skyflowClient.insertBulk(records);
-
-            System.out.println(res);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if(Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
\ No newline at end of file
diff --git a/samples/src/main/java/com/example/InsertBulkWithUpsertExample.java b/samples/src/main/java/com/example/InsertBulkWithUpsertExample.java
deleted file mode 100644
index 57272e15..00000000
--- a/samples/src/main/java/com/example/InsertBulkWithUpsertExample.java
+++ /dev/null
@@ -1,69 +0,0 @@
-package com.example;
-
-import com.skyflow.entities.*;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-
-public class InsertBulkWithUpsertExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record = new JSONObject();
-            record.put("table", "<your_table_name>");
-
-            JSONObject fields = new JSONObject();
-            fields.put("<field_name", "<your_field_value>");
-
-            record.put("fields", fields);
-            recordsArray.add(record);
-
-            records.put("records", recordsArray);
-
-            // create an upsert option and insert in UpsertOptions array.
-            UpsertOption[] upsertOptions = new UpsertOption[1];
-            upsertOptions[0] = new UpsertOption("<table_name>", "<unique_column_name>");
-
-            // pass upsert options in insert method options.
-            InsertBulkOptions insertOptions = new InsertBulkOptions(true, upsertOptions);
-            JSONObject res = skyflowClient.insertBulk(records, insertOptions);
-
-            System.out.println(res);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if (Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/InsertExample.java b/samples/src/main/java/com/example/InsertExample.java
deleted file mode 100644
index faada157..00000000
--- a/samples/src/main/java/com/example/InsertExample.java
+++ /dev/null
@@ -1,66 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc. 
-*/
-package com.example;
-
-import com.skyflow.entities.InsertOptions;
-import com.skyflow.entities.ResponseToken;
-import com.skyflow.entities.SkyflowConfiguration;
-import com.skyflow.entities.TokenProvider;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-public class InsertExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record = new JSONObject();
-            record.put("table", "<your_table_name>");
-
-            JSONObject fields = new JSONObject();
-            fields.put("<your_field_name>", "<your_field_value>");
-            record.put("fields", fields);
-            recordsArray.add(record);
-            records.put("records", recordsArray);
-
-            InsertOptions insertOptions = new InsertOptions();
-            JSONObject res = skyflowClient.insert(records, insertOptions);
-
-            System.out.println(res);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if(Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/InsertWithContinueOnErrorExample.java b/samples/src/main/java/com/example/InsertWithContinueOnErrorExample.java
deleted file mode 100644
index 21e7df2f..00000000
--- a/samples/src/main/java/com/example/InsertWithContinueOnErrorExample.java
+++ /dev/null
@@ -1,69 +0,0 @@
-/*
-	Copyright (c) 2024 Skyflow, Inc. 
-*/
-import com.skyflow.entities.*;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-public class InsertWithContinueOnErrorExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration(
-                "<VAULT_ID>",
-                "<VAULT_URL>",
-                new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record1 = new JSONObject();
-            record1.put("table", "<your_table_name>");
-            JSONObject fields = new JSONObject();
-            fields.put("<field_name>", "<your_field_value>");
-            record1.put("fields", fields);
-
-            JSONObject record2 = new JSONObject();
-            record2.put("table", "<your_table_name>");
-            JSONObject fields2 = new JSONObject();
-            fields2.put("<field_name>", "<your_field_value>");
-            record2.put("fields", fields2);
-
-            recordsArray.add(record1);
-            recordsArray.add(record2);
-            records.put("records", recordsArray);
-
-            InsertOptions insertOptions = new InsertOptions(true,true);
-            JSONObject insertResponse = skyflowClient.insert(records, insertOptions);
-            System.out.println(insertResponse);
-        } catch (SkyflowException e) {
-            System.out.println(e);
-            e.printStackTrace();
-        }
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if (Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/InsertWithUpsertExample.java b/samples/src/main/java/com/example/InsertWithUpsertExample.java
deleted file mode 100644
index 3ae13357..00000000
--- a/samples/src/main/java/com/example/InsertWithUpsertExample.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc.
-*/
-package com.example;
-
-import com.skyflow.entities.*;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-public class InsertWithUpsertExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-
-            JSONObject record = new JSONObject();
-            record.put("table", "<your_table_name>");
-
-            JSONObject fields = new JSONObject();
-            fields.put("<field_name", "<your_field_value>");
-
-            record.put("fields", fields);
-            recordsArray.add(record);
-
-            records.put("records", recordsArray);
-
-            // create an upsert option and insert in UpsertOptions array.
-            UpsertOption[] upsertOptions = new UpsertOption[1];
-            upsertOptions[0] = new UpsertOption("<table_name>", "<unique_column_name>");
-
-            // pass upsert options in insert method options.
-            InsertOptions insertOptions = new InsertOptions(true, upsertOptions);
-            JSONObject res = skyflowClient.insert(records, insertOptions);
-
-            System.out.println(res);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if (Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/InvokeConnectionExample.java b/samples/src/main/java/com/example/InvokeConnectionExample.java
deleted file mode 100644
index 8f5eac28..00000000
--- a/samples/src/main/java/com/example/InvokeConnectionExample.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc. 
-*/
-import com.skyflow.entities.*;
-import com.skyflow.vault.Skyflow;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-public class InvokeConnectionExample {
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if(Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-
-    public static void main(String[] args) {
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-            JSONObject testConfig = new JSONObject();
-            testConfig.put("connectionURL", "<your_connection_url>");
-            testConfig.put("methodName", RequestMethod.POST);
-
-            JSONObject pathParamsJson = new JSONObject();
-            pathParamsJson.put("<path_param_key>", "<path_param_value>");
-            testConfig.put("pathParams", pathParamsJson);
-
-            JSONObject queryParamsJson = new JSONObject();
-            queryParamsJson.put("<query_param_key>", "<query_param_value>");
-            testConfig.put("queryParams", queryParamsJson);
-
-            JSONObject requestHeadersJson = new JSONObject();
-            requestHeadersJson.put("<request_header_key>", "<request_header_value>");
-            testConfig.put("requestHeader", requestHeadersJson);
-
-            JSONObject requestBodyJson = new JSONObject();
-            requestBodyJson.put("<request_body_key>", "<request_body_value>");
-            testConfig.put("requestBody", requestBodyJson);
-
-            JSONObject gatewayResponse = skyflowClient.invokeConnection(testConfig);
-            System.out.println(gatewayResponse);
-
-        } catch (SkyflowException exception) {
-            exception.printStackTrace();
-        }
-    }
-}
\ No newline at end of file
diff --git a/samples/src/main/java/com/example/QueryExample.java b/samples/src/main/java/com/example/QueryExample.java
deleted file mode 100644
index 31d577c7..00000000
--- a/samples/src/main/java/com/example/QueryExample.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc.
-*/
-package com.example;
-
-import com.skyflow.entities.ResponseToken;
-import com.skyflow.entities.SkyflowConfiguration;
-import com.skyflow.entities.TokenProvider;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONObject;
-
-public class QueryExample {
-
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-
-            JSONObject queryInput = new JSONObject();
-
-            queryInput.put("query", "<YOUR_SQL_QUERY>");
-
-            JSONObject res = skyflowClient.query(queryInput);
-
-            System.out.println(res);
-        } catch (SkyflowException e) {
-            System.out.println(e.getData());
-            e.printStackTrace();
-        }
-
-    }
-
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if(Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
\ No newline at end of file
diff --git a/samples/src/main/java/com/example/ScopedTokenGenerationExample.java b/samples/src/main/java/com/example/ScopedTokenGenerationExample.java
deleted file mode 100644
index ed4dda5f..00000000
--- a/samples/src/main/java/com/example/ScopedTokenGenerationExample.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc.
-*/
-package com.example;
-
-import com.skyflow.serviceaccount.util.BearerToken;
-import java.io.File;
-
-public class ScopedTokenGenerationExample {
-    public static void main(String args[]) {
-
-        String scopedToken = null;
-
-        // Generate Scoped Token  by specifying credentials.json file path
-        try {
-            String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-            BearerToken token = new BearerToken.BearerTokenBuilder()
-                    .setCredentials(new File(filePath))
-                    .setRoles(new String[]{"roleID"})
-                    .build();
-
-            scopedToken = token.getBearerToken();
-            System.out.println(scopedToken);
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-}
diff --git a/samples/src/main/java/com/example/TokenGenerationExample.java b/samples/src/main/java/com/example/TokenGenerationExample.java
deleted file mode 100644
index b4de6b87..00000000
--- a/samples/src/main/java/com/example/TokenGenerationExample.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc. 
-*/
-package com.example;
-
-import com.skyflow.entities.ResponseToken;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-
-public class TokenGenerationExample {
-    public static void main(String args[]) {
-
-        String bearerToken = null;
-
-        // Generate BearerToken by specifying credentials.json file path
-        try {
-            String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-            if(Token.isExpired(bearerToken)) {
-                ResponseToken res = Token.generateBearerToken(filePath);
-                bearerToken = res.getAccessToken();
-            }
-            System.out.println(bearerToken);
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-
-        // Generate BearerToken by specifying credentials.json as string
-        try {
-            String fileContents = "<YOUR_CREDENTIALS_FILE_CONTENTS_AS_STRING>";
-            if(Token.isExpired(bearerToken)) {
-                ResponseToken res = Token.generateBearerTokenFromCreds(fileContents);
-                bearerToken = res.getAccessToken();
-            }
-            System.out.println(bearerToken);
-        } catch (SkyflowException e) {
-            e.printStackTrace();
-        }
-
-    }
-}
diff --git a/samples/src/main/java/com/example/UpdateExample.java b/samples/src/main/java/com/example/UpdateExample.java
deleted file mode 100644
index 5e67d7ec..00000000
--- a/samples/src/main/java/com/example/UpdateExample.java
+++ /dev/null
@@ -1,59 +0,0 @@
-import com.skyflow.entities.*;
-import com.skyflow.errors.SkyflowException;
-import com.skyflow.serviceaccount.util.Token;
-import com.skyflow.vault.Skyflow;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-public class UpdateExample {
-    public static void main(String[] args) {
-
-        try {
-            SkyflowConfiguration config = new SkyflowConfiguration("<your_vaultID>",
-                    "<your_vaultURL>", new DemoTokenProvider());
-            Skyflow skyflowClient = Skyflow.init(config);
-
-            JSONObject records = new JSONObject();
-            JSONArray recordsArray = new JSONArray();
-            JSONObject record = new JSONObject();
-
-            record.put("table", "<your_table_name>");
-            record.put("id", "<your_skyflow_id>");
-
-            JSONObject fields = new JSONObject();
-            fields.put("<your_field_name>", "<your_field_value>");
-            record.put("fields", fields);
-            recordsArray.add(record);
-            records.put("records", recordsArray);
-
-            UpdateOptions updateOptions = new UpdateOptions(true);
-            JSONObject res = skyflowClient.update(records, updateOptions);
-
-        }
-        catch (SkyflowException e) {
-            System.out.println(e.getData());
-            e.printStackTrace();
-        }
-    }
-    static class DemoTokenProvider implements TokenProvider {
-
-        private String bearerToken = null;
-
-        @Override
-        public String getBearerToken() throws Exception {
-            ResponseToken response = null;
-            try {
-                String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
-                if(Token.isExpired(bearerToken)) {
-                    response = Token.generateBearerToken(filePath);
-                    bearerToken = response.getAccessToken();
-                }
-            } catch (SkyflowException e) {
-                e.printStackTrace();
-            }
-
-            return bearerToken;
-        }
-    }
-}
-
diff --git a/samples/src/main/java/com/example/connection/InvokeConnectionExample.java b/samples/src/main/java/com/example/connection/InvokeConnectionExample.java
new file mode 100644
index 00000000..1c1ee12f
--- /dev/null
+++ b/samples/src/main/java/com/example/connection/InvokeConnectionExample.java
@@ -0,0 +1,68 @@
+package com.example.connection;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.ConnectionConfig;
+import com.skyflow.config.Credentials;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.enums.RequestMethod;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.connection.InvokeConnectionRequest;
+import com.skyflow.vault.connection.InvokeConnectionResponse;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class InvokeConnectionExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<path_to_your_credentials_file_1>");
+
+        ConnectionConfig connectionConfig1 = new ConnectionConfig();
+        connectionConfig1.setConnectionId("<your_connection_id_1>");
+        connectionConfig1.setConnectionUrl("<your_connection_url_1>");
+        connectionConfig1.setCredentials(credentials);
+
+        ConnectionConfig connectionConfig2 = new ConnectionConfig();
+        connectionConfig2.setConnectionId("<your_connection_id_2>");
+        connectionConfig2.setConnectionUrl("<your_connection_url_2>");
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<path_to_your_credentials_file_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addConnectionConfig(connectionConfig1)
+                .addConnectionConfig(connectionConfig2)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        Map<String, String> requestBody = new HashMap<>();
+        requestBody.put("<column_name_1>", "<column_value_1>");
+        requestBody.put("<column_name_2>", "<column_value_2>");
+        Map<String, String> requestHeaders = new HashMap<>();
+        requestHeaders.put("<header_name_1>", "<header_value_1>");
+        requestHeaders.put("<header_name_2>", "<header_value_2>");
+        InvokeConnectionRequest invokeConnectionRequest1 = InvokeConnectionRequest.builder()
+                .methodName(RequestMethod.POST)
+                .requestBody(requestBody)
+                .requestHeaders(requestHeaders)
+                .build();
+        InvokeConnectionResponse invokeConnectionResponse1 = skyflowClient.connection().invoke(invokeConnectionRequest1);
+        System.out.println(invokeConnectionResponse1);
+
+        Map<String, String> pathParams = new HashMap<>();
+        pathParams.put("<your_path_param_key_1>", "<your_path_param_value_1>");
+        pathParams.put("<your_path_param_key_2>", "<your_path_param_value_2>");
+        Map<String, String> queryParams = new HashMap<>();
+        queryParams.put("<your_query_param_key_1>", "<your_query_param_value_1>");
+        queryParams.put("<your_query_param_key_2>", "<your_query_param_value_2>");
+        InvokeConnectionRequest invokeConnectionRequest2 = InvokeConnectionRequest.builder()
+                .methodName(RequestMethod.GET)
+                .pathParams(pathParams)
+                .queryParams(queryParams)
+                .build();
+        InvokeConnectionResponse invokeConnectionResponse2 = skyflowClient
+                .connection("<your_connection_id_2>").invoke(invokeConnectionRequest2);
+        System.out.println(invokeConnectionResponse2);
+    }
+}
diff --git a/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationExample.java b/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationExample.java
new file mode 100644
index 00000000..ae1bce1b
--- /dev/null
+++ b/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationExample.java
@@ -0,0 +1,37 @@
+package com.example.serviceaccount;
+
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.serviceaccount.util.BearerToken;
+import com.skyflow.serviceaccount.util.Token;
+
+import java.io.File;
+
+public class BearerTokenGenerationExample {
+    public static void main(String[] args) {
+        String token = null;
+
+        // Generate BearerToken by specifying credentials.json file path
+        try {
+            String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
+            if (Token.isExpired(token)) {
+                BearerToken bearerToken = BearerToken.builder().setCredentials(new File(filePath)).build();
+                token = bearerToken.getBearerToken();
+            }
+            System.out.println(token);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        // Generate BearerToken by specifying credentials.json as string
+        try {
+            String fileContents = "<YOUR_CREDENTIALS_FILE_CONTENTS_AS_STRING>";
+            if (Token.isExpired(token)) {
+                BearerToken bearerToken = BearerToken.builder().setCredentials(fileContents).build();
+                token = bearerToken.getBearerToken();
+            }
+            System.out.println(token);
+        } catch (SkyflowException e) {
+            e.printStackTrace();
+        }
+    }
+}
\ No newline at end of file
diff --git a/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationUsingThreadsExample.java b/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationUsingThreadsExample.java
new file mode 100644
index 00000000..1d750ade
--- /dev/null
+++ b/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationUsingThreadsExample.java
@@ -0,0 +1,60 @@
+package com.example.serviceaccount;
+
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.serviceaccount.util.BearerToken;
+
+import java.io.File;
+
+public class BearerTokenGenerationUsingThreadsExample {
+    public static void main(String[] args) {
+        // Generate BearerToken with context by specifying credentials.json file path
+        try {
+            String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
+            final BearerToken bearerToken = new BearerToken.BearerTokenBuilder()
+                    .setCredentials(new File(filePath))
+                    .setCtx("abc")
+                    .build();
+
+            Thread t = new Thread(() -> {
+                for (int i = 0; i < 5; i++) {
+                    try {
+                        System.out.println(bearerToken.getBearerToken());
+                    } catch (SkyflowException e) {
+                        Thread.currentThread().interrupt();
+                        throw new RuntimeException(e);
+
+                    }
+
+                }
+            });
+            t.start();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        // Generate BearerToken with context by specifying credentials.json as string
+        try {
+            String fileContents = "<YOUR_CREDENTIALS_FILE_CONTENTS_AS_STRING>";
+            final BearerToken bearerToken = new BearerToken.BearerTokenBuilder()
+                    .setCredentials(fileContents)
+                    .setCtx("abc")
+                    .build();
+
+            Thread t = new Thread(() -> {
+                for (int i = 0; i < 5; i++) {
+                    try {
+                        System.out.println(bearerToken.getBearerToken());
+                    } catch (SkyflowException e) {
+                        Thread.currentThread().interrupt();
+                        throw new RuntimeException(e);
+
+                    }
+
+                }
+            });
+            t.start();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}
\ No newline at end of file
diff --git a/samples/src/main/java/com/example/BearerTokenWithContextGenerationExample.java b/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationWithContextExample.java
similarity index 88%
rename from samples/src/main/java/com/example/BearerTokenWithContextGenerationExample.java
rename to samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationWithContextExample.java
index 668b7c81..69e6ff14 100644
--- a/samples/src/main/java/com/example/BearerTokenWithContextGenerationExample.java
+++ b/samples/src/main/java/com/example/serviceaccount/BearerTokenGenerationWithContextExample.java
@@ -1,16 +1,12 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc.
-*/
-package com.example;
+package com.example.serviceaccount;
 
 import com.skyflow.errors.SkyflowException;
 import com.skyflow.serviceaccount.util.BearerToken;
 
 import java.io.File;
 
-public class BearerTokenWithContextGenerationExample {
-    public static void main(String args[]) {
-
+public class BearerTokenGenerationWithContextExample {
+    public static void main(String[] args) {
         String bearerToken = null;
 
         // Generate BearerToken with context by specifying credentials.json file path
@@ -37,10 +33,8 @@ public static void main(String args[]) {
 
             bearerToken = token.getBearerToken();
             System.out.println(bearerToken);
-
         } catch (SkyflowException e) {
             e.printStackTrace();
         }
-
     }
 }
diff --git a/samples/src/main/java/com/example/serviceaccount/ScopedTokenGenerationExample.java b/samples/src/main/java/com/example/serviceaccount/ScopedTokenGenerationExample.java
new file mode 100644
index 00000000..b8dfbc53
--- /dev/null
+++ b/samples/src/main/java/com/example/serviceaccount/ScopedTokenGenerationExample.java
@@ -0,0 +1,45 @@
+package com.example.serviceaccount;
+
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.serviceaccount.util.BearerToken;
+
+import java.io.File;
+import java.util.ArrayList;
+
+public class ScopedTokenGenerationExample {
+    public static void main(String[] args) {
+        String scopedToken = null;
+
+        // Generate Scoped Token  by specifying credentials.json file path
+        try {
+            ArrayList<String> roles = new ArrayList<>();
+            roles.add("YOUR_ROLE_ID");
+            String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
+            BearerToken bearerToken = new BearerToken.BearerTokenBuilder()
+                    .setCredentials(new File(filePath))
+                    .setRoles(roles)
+                    .build();
+
+            scopedToken = bearerToken.getBearerToken();
+            System.out.println(scopedToken);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        // Generate BearerToken with context by specifying credentials.json as string
+        try {
+            ArrayList<String> roles = new ArrayList<>();
+            roles.add("YOUR_ROLE_ID");
+            String fileContents = "<YOUR_CREDENTIALS_FILE_CONTENTS_AS_STRING>";
+            BearerToken bearerToken = new BearerToken.BearerTokenBuilder()
+                    .setCredentials(fileContents)
+                    .setRoles(roles)
+                    .build();
+
+            scopedToken = bearerToken.getBearerToken();
+            System.out.println(scopedToken);
+        } catch (SkyflowException e) {
+            e.printStackTrace();
+        }
+    }
+}
\ No newline at end of file
diff --git a/samples/src/main/java/com/example/SignedTokenGenerationExample.java b/samples/src/main/java/com/example/serviceaccount/SignedTokenGenerationExample.java
similarity index 63%
rename from samples/src/main/java/com/example/SignedTokenGenerationExample.java
rename to samples/src/main/java/com/example/serviceaccount/SignedTokenGenerationExample.java
index 1fde4236..7f030838 100644
--- a/samples/src/main/java/com/example/SignedTokenGenerationExample.java
+++ b/samples/src/main/java/com/example/serviceaccount/SignedTokenGenerationExample.java
@@ -1,32 +1,32 @@
-/*
-	Copyright (c) 2022 Skyflow, Inc.
-*/
-package com.example;
+package com.example.serviceaccount;
 
 import com.skyflow.errors.SkyflowException;
 import com.skyflow.serviceaccount.util.SignedDataTokenResponse;
 import com.skyflow.serviceaccount.util.SignedDataTokens;
 
 import java.io.File;
+import java.util.ArrayList;
 import java.util.List;
 
 public class SignedTokenGenerationExample {
-    public static void main(String args[]) {
-
-        List<SignedDataTokenResponse> signedTokenValue;
+    public static void main(String[] args) {
+        List<SignedDataTokenResponse> signedTokenValues;
 
         // Generate Signed data token with context by specifying credentials.json file path
         try {
             String filePath = "<YOUR_CREDENTIALS_FILE_PATH>";
             String context = "abc";
+            ArrayList<String> dataTokens = new ArrayList<>();
+            dataTokens.add("YOUR_DATA_TOKEN_1");
             SignedDataTokens signedToken = new SignedDataTokens.SignedDataTokensBuilder()
                     .setCredentials(new File(filePath))
                     .setCtx(context)
                     .setTimeToLive(30) // in seconds
-                    .setDataTokens(new String[]{"dataToken1"}).build();
+                    .setDataTokens(dataTokens)
+                    .build();
 
-            signedTokenValue =  signedToken.getSignedDataTokens();
-            System.out.println(signedTokenValue);
+            signedTokenValues = signedToken.getSignedDataTokens();
+            System.out.println(signedTokenValues);
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -35,19 +35,21 @@ public static void main(String args[]) {
         try {
             String fileContents = "<YOUR_CREDENTIALS_FILE_CONTENTS_AS_STRING>";
             String context = "abc";
+            ArrayList<String> dataTokens = new ArrayList<>();
+            dataTokens.add("YOUR_DATA_TOKEN_1");
             SignedDataTokens signedToken = new SignedDataTokens.SignedDataTokensBuilder()
                     .setCredentials(fileContents)
                     .setCtx(context)
                     .setTimeToLive(30) // in seconds
-                    .setDataTokens(new String[]{"dataToken1"}).build();
+                    .setDataTokens(dataTokens)
+                    .build();
 
-            signedTokenValue =  signedToken.getSignedDataTokens();
-            System.out.println(signedTokenValue);
+            signedTokenValues = signedToken.getSignedDataTokens();
+            System.out.println(signedTokenValues);
 
         } catch (SkyflowException e) {
             e.printStackTrace();
         }
-
-
     }
 }
+
diff --git a/samples/src/main/java/com/example/vault/DeleteExample.java b/samples/src/main/java/com/example/vault/DeleteExample.java
new file mode 100644
index 00000000..17887204
--- /dev/null
+++ b/samples/src/main/java/com/example/vault/DeleteExample.java
@@ -0,0 +1,52 @@
+package com.example.vault;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.Credentials;
+import com.skyflow.config.VaultConfig;
+import com.skyflow.enums.Env;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.data.DeleteRequest;
+import com.skyflow.vault.data.DeleteResponse;
+
+import java.util.ArrayList;
+
+public class DeleteExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_1>");
+
+        VaultConfig blitzConfig = new VaultConfig();
+        blitzConfig.setVaultId("<YOUR_VAULT_ID_1>");
+        blitzConfig.setClusterId("<YOUR_CLUSTER_ID_1>");
+        blitzConfig.setEnv(Env.DEV);
+        blitzConfig.setCredentials(credentials);
+
+        VaultConfig stageConfig = new VaultConfig();
+        stageConfig.setVaultId("<YOUR_VAULT_ID_2>");
+        stageConfig.setClusterId("<YOUR_CLUSTER_ID_2>");
+        stageConfig.setEnv(Env.STAGE);
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addVaultConfig(blitzConfig)
+                .addVaultConfig(stageConfig)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        ArrayList<String> ids1 = new ArrayList<>();
+        ids1.add("<your_token_value>");
+        DeleteRequest deleteRequest1 = DeleteRequest.builder().ids(ids1).table("<table_name>").build();
+        DeleteResponse deleteResponse1 = skyflowClient.vault().delete(deleteRequest1);
+        System.out.println(deleteResponse1);
+
+        ArrayList<String> ids2 = new ArrayList<>();
+        ids2.add("<your_token_value>");
+        DeleteRequest deleteRequest2 = DeleteRequest.builder().ids(ids2).table("<table_name>").build();
+        DeleteResponse deleteResponse2 = skyflowClient.vault("<your_vault_id_2>").delete(deleteRequest2);
+        System.out.println(deleteResponse2);
+    }
+}
diff --git a/samples/src/main/java/com/example/vault/DetokenizeExample.java b/samples/src/main/java/com/example/vault/DetokenizeExample.java
new file mode 100644
index 00000000..f026e43e
--- /dev/null
+++ b/samples/src/main/java/com/example/vault/DetokenizeExample.java
@@ -0,0 +1,57 @@
+package com.example.vault;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.Credentials;
+import com.skyflow.config.VaultConfig;
+import com.skyflow.enums.Env;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.enums.RedactionType;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.tokens.DetokenizeRequest;
+import com.skyflow.vault.tokens.DetokenizeResponse;
+
+import java.util.ArrayList;
+
+public class DetokenizeExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_1>");
+
+        VaultConfig blitzConfig = new VaultConfig();
+        blitzConfig.setVaultId("<YOUR_VAULT_ID_1>");
+        blitzConfig.setClusterId("<YOUR_CLUSTER_ID_1>");
+        blitzConfig.setEnv(Env.DEV);
+        blitzConfig.setCredentials(credentials);
+
+        VaultConfig stageConfig = new VaultConfig();
+        stageConfig.setVaultId("<YOUR_VAULT_ID_2>");
+        stageConfig.setClusterId("<YOUR_CLUSTER_ID_2>");
+        stageConfig.setEnv(Env.STAGE);
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addVaultConfig(blitzConfig)
+                .addVaultConfig(stageConfig)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        ArrayList<String> tokens1 = new ArrayList<>();
+        tokens1.add("<your_token_value_1>");
+        tokens1.add("<your_token_value_2>");
+        DetokenizeRequest detokenizeRequest1 = DetokenizeRequest.builder().tokens(tokens1).continueOnError(true).build();
+        DetokenizeResponse detokenizeResponse1 = skyflowClient.vault().detokenize(detokenizeRequest1);
+        System.out.println(detokenizeResponse1);
+
+        ArrayList<String> tokens2 = new ArrayList<>();
+        tokens2.add("<your_token_value_1>");
+        tokens2.add("<your_token_value_2>");
+
+        DetokenizeRequest detokenizeRequest2 = DetokenizeRequest.builder()
+                .tokens(tokens2).continueOnError(false).redactionType(RedactionType.DEFAULT).build();
+        DetokenizeResponse detokenizeResponse2 = skyflowClient.vault("<your_vault_id_2>").detokenize(detokenizeRequest2);
+        System.out.println(detokenizeResponse2);
+    }
+}
diff --git a/samples/src/main/java/com/example/vault/GetExample.java b/samples/src/main/java/com/example/vault/GetExample.java
new file mode 100644
index 00000000..357c3516
--- /dev/null
+++ b/samples/src/main/java/com/example/vault/GetExample.java
@@ -0,0 +1,58 @@
+package com.example.vault;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.Credentials;
+import com.skyflow.config.VaultConfig;
+import com.skyflow.enums.Env;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.enums.RedactionType;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.data.GetRequest;
+import com.skyflow.vault.data.GetResponse;
+
+import java.util.ArrayList;
+
+public class GetExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_1>");
+
+        VaultConfig blitzConfig = new VaultConfig();
+        blitzConfig.setVaultId("<YOUR_VAULT_ID_1>");
+        blitzConfig.setClusterId("<YOUR_CLUSTER_ID_1>");
+        blitzConfig.setEnv(Env.DEV);
+        blitzConfig.setCredentials(credentials);
+
+        VaultConfig stageConfig = new VaultConfig();
+        stageConfig.setVaultId("<YOUR_VAULT_ID_2>");
+        stageConfig.setClusterId("<YOUR_CLUSTER_ID_2>");
+        stageConfig.setEnv(Env.STAGE);
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addVaultConfig(blitzConfig)
+                .addVaultConfig(stageConfig)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        ArrayList<String> ids = new ArrayList<>();
+        ids.add("<your_skyflow_id>");
+        GetRequest getByIdRequest = GetRequest.builder().returnTokens(true).ids(ids).table("<table_name>").build();
+        GetResponse getByIdResponse = skyflowClient.vault().get(getByIdRequest);
+        System.out.println(getByIdResponse);
+
+        ArrayList<String> columnValues = new ArrayList<>();
+        columnValues.add("<your_skyflow_id>");
+        GetRequest getByColumnRequest = GetRequest.builder()
+                .table("<table_name>")
+                .columnName("<column_name>")
+                .columnValues(columnValues)
+                .redactionType(RedactionType.PLAIN_TEXT)
+                .build();
+        GetResponse getByColumnResponse = skyflowClient.vault("<your_vault_id_2>").get(getByColumnRequest);
+        System.out.println(getByColumnResponse);
+    }
+}
diff --git a/samples/src/main/java/com/example/vault/InsertExample.java b/samples/src/main/java/com/example/vault/InsertExample.java
new file mode 100644
index 00000000..21d9260b
--- /dev/null
+++ b/samples/src/main/java/com/example/vault/InsertExample.java
@@ -0,0 +1,81 @@
+package com.example.vault;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.Credentials;
+import com.skyflow.config.VaultConfig;
+import com.skyflow.enums.Byot;
+import com.skyflow.enums.Env;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.data.InsertRequest;
+import com.skyflow.vault.data.InsertResponse;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+
+public class InsertExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_1>");
+
+        VaultConfig blitzConfig = new VaultConfig();
+        blitzConfig.setVaultId("<YOUR_VAULT_ID_1>");
+        blitzConfig.setClusterId("<YOUR_CLUSTER_ID_1>");
+        blitzConfig.setEnv(Env.DEV);
+        blitzConfig.setCredentials(credentials);
+
+        VaultConfig stageConfig = new VaultConfig();
+        stageConfig.setVaultId("<YOUR_VAULT_ID_2>");
+        stageConfig.setClusterId("<YOUR_CLUSTER_ID_2>");
+        stageConfig.setEnv(Env.STAGE);
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addVaultConfig(blitzConfig)
+                .addVaultConfig(stageConfig)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        ArrayList<HashMap<String, Object>> values1 = new ArrayList<>();
+        HashMap<String, Object> value1 = new HashMap<>();
+        value1.put("<column_name_1>", "<column_value_1>");
+        value1.put("<column_name_2>", "<column_value_2>");
+        values1.add(value1);
+
+        ArrayList<HashMap<String, Object>> tokens = new ArrayList<>();
+        HashMap<String, Object> token = new HashMap<>();
+        token.put("<column_name_2>", "<token_value_2>");
+        tokens.add(token);
+
+        InsertRequest insertRequest = InsertRequest.builder()
+                .table("<table_name>")
+                .continueOnError(true)
+                .tokenStrict(Byot.ENABLE)
+                .values(values1)
+                .tokens(tokens)
+                .returnTokens(true)
+                .build();
+        InsertResponse insertResponse = skyflowClient.vault().insert(insertRequest);
+        System.out.println(insertResponse);
+
+        ArrayList<HashMap<String, Object>> values2 = new ArrayList<>();
+        HashMap<String, Object> value2 = new HashMap<>();
+        value2.put("<column_name_1>", "<column_value_1>");
+        value2.put("<column_name_2>", "<column_value_1>");
+        values2.add(value2);
+
+        InsertRequest upsertRequest = InsertRequest.builder()
+                .table("<table_name>")
+                .continueOnError(false)
+                .tokenStrict(Byot.DISABLE)
+                .values(values2)
+                .returnTokens(false)
+                .upsert("<upsert_column>")
+                .build();
+        InsertResponse upsertResponse = skyflowClient.vault("<your_vault_id_2>").insert(upsertRequest);
+        System.out.println(upsertResponse);
+    }
+}
diff --git a/samples/src/main/java/com/example/vault/QueryExample.java b/samples/src/main/java/com/example/vault/QueryExample.java
new file mode 100644
index 00000000..c80a2443
--- /dev/null
+++ b/samples/src/main/java/com/example/vault/QueryExample.java
@@ -0,0 +1,49 @@
+package com.example.vault;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.Credentials;
+import com.skyflow.config.VaultConfig;
+import com.skyflow.enums.Env;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.data.QueryRequest;
+import com.skyflow.vault.data.QueryResponse;
+
+public class QueryExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_1>");
+
+        VaultConfig blitzConfig = new VaultConfig();
+        blitzConfig.setVaultId("<YOUR_VAULT_ID_1>");
+        blitzConfig.setClusterId("<YOUR_CLUSTER_ID_1>");
+        blitzConfig.setEnv(Env.DEV);
+        blitzConfig.setCredentials(credentials);
+
+        VaultConfig stageConfig = new VaultConfig();
+        stageConfig.setVaultId("<YOUR_VAULT_ID_2>");
+        stageConfig.setClusterId("<YOUR_CLUSTER_ID_2>");
+        stageConfig.setEnv(Env.STAGE);
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addVaultConfig(blitzConfig)
+                .addVaultConfig(stageConfig)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        String query1 = "<your_sql_query>";
+        QueryRequest queryRequest1 = QueryRequest.builder().query(query1).build();
+        QueryResponse queryResponse1 = skyflowClient.vault().query(queryRequest1);
+        System.out.println(queryResponse1);
+
+        String query2 = "<your_sql_query>";
+        QueryRequest queryRequest2 = QueryRequest.builder().query(query2).build();
+        QueryResponse queryResponse2 = skyflowClient.vault("<your_vault_id_2>").query(queryRequest2);
+        System.out.println(queryResponse2);
+
+    }
+}
diff --git a/samples/src/main/java/com/example/vault/TokenizeExample.java b/samples/src/main/java/com/example/vault/TokenizeExample.java
new file mode 100644
index 00000000..f7677670
--- /dev/null
+++ b/samples/src/main/java/com/example/vault/TokenizeExample.java
@@ -0,0 +1,60 @@
+package com.example.vault;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.Credentials;
+import com.skyflow.config.VaultConfig;
+import com.skyflow.enums.Env;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.tokens.ColumnValue;
+import com.skyflow.vault.tokens.TokenizeRequest;
+import com.skyflow.vault.tokens.TokenizeResponse;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class TokenizeExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_1>");
+
+        VaultConfig blitzConfig = new VaultConfig();
+        blitzConfig.setVaultId("<YOUR_VAULT_ID_1>");
+        blitzConfig.setClusterId("<YOUR_CLUSTER_ID_1>");
+        blitzConfig.setEnv(Env.DEV);
+        blitzConfig.setCredentials(credentials);
+
+        VaultConfig stageConfig = new VaultConfig();
+        stageConfig.setVaultId("<YOUR_VAULT_ID_2>");
+        stageConfig.setClusterId("<YOUR_CLUSTER_ID_2>");
+        stageConfig.setEnv(Env.STAGE);
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addVaultConfig(blitzConfig)
+                .addVaultConfig(stageConfig)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        List<ColumnValue> columnValues1 = new ArrayList<>();
+        ColumnValue value1 = ColumnValue.builder().value("<your_value>").columnGroup("<your_column_group>").build();
+        ColumnValue value2 = ColumnValue.builder().value("<your_value>").columnGroup("<your_column_group>").build();
+        columnValues1.add(value1);
+        columnValues1.add(value2);
+        TokenizeRequest tokenizeRequest1 = TokenizeRequest.builder().values(columnValues1).build();
+        TokenizeResponse tokenizeResponse1 = skyflowClient.vault().tokenize(tokenizeRequest1);
+        System.out.println(tokenizeResponse1);
+
+        List<ColumnValue> columnValues2 = new ArrayList<>();
+        ColumnValue value3 = ColumnValue.builder().value("<your_value>").columnGroup("<your_column_group>").build();
+        ColumnValue value4 = ColumnValue.builder().value("<your_value>").columnGroup("<your_column_group>").build();
+        columnValues2.add(value3);
+        columnValues2.add(value4);
+        TokenizeRequest tokenizeRequest2 = TokenizeRequest.builder().values(columnValues2).build();
+        TokenizeResponse tokenizeResponse2 = skyflowClient.vault("<your_vault_id_2>").tokenize(tokenizeRequest2);
+        System.out.println(tokenizeResponse2);
+    }
+}
diff --git a/samples/src/main/java/com/example/vault/UpdateExample.java b/samples/src/main/java/com/example/vault/UpdateExample.java
new file mode 100644
index 00000000..b782d80d
--- /dev/null
+++ b/samples/src/main/java/com/example/vault/UpdateExample.java
@@ -0,0 +1,73 @@
+package com.example.vault;
+
+import com.skyflow.Skyflow;
+import com.skyflow.config.Credentials;
+import com.skyflow.config.VaultConfig;
+import com.skyflow.enums.Byot;
+import com.skyflow.enums.Env;
+import com.skyflow.enums.LogLevel;
+import com.skyflow.errors.SkyflowException;
+import com.skyflow.vault.data.UpdateRequest;
+import com.skyflow.vault.data.UpdateResponse;
+
+import java.util.HashMap;
+
+public class UpdateExample {
+    public static void main(String[] args) throws SkyflowException {
+        Credentials credentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_1>");
+
+        VaultConfig blitzConfig = new VaultConfig();
+        blitzConfig.setVaultId("<YOUR_VAULT_ID_1>");
+        blitzConfig.setClusterId("<YOUR_CLUSTER_ID_1>");
+        blitzConfig.setEnv(Env.DEV);
+        blitzConfig.setCredentials(credentials);
+
+        VaultConfig stageConfig = new VaultConfig();
+        stageConfig.setVaultId("<YOUR_VAULT_ID_2>");
+        stageConfig.setClusterId("<YOUR_CLUSTER_ID_2>");
+        stageConfig.setEnv(Env.STAGE);
+
+        Credentials skyflowCredentials = new Credentials();
+        credentials.setPath("<YOUR_CREDENTIALS_FILE_PATH_2>");
+
+        Skyflow skyflowClient = Skyflow.builder()
+                .setLogLevel(LogLevel.DEBUG)
+                .addVaultConfig(blitzConfig)
+                .addVaultConfig(stageConfig)
+                .addSkyflowCredentials(skyflowCredentials)
+                .build();
+
+        HashMap<String, Object> values1 = new HashMap<>();
+        values1.put("<column_name_1>", "<column_value_1>");
+        values1.put("<column_name_2>", "<column_value_1>");
+
+        HashMap<String, Object> tokens = new HashMap<>();
+        tokens.put("<column_name_2>", "<token_value_2>");
+
+        UpdateRequest updateRequest1 = UpdateRequest.builder()
+                .id("<your_skyflow_id")
+                .table("<table_name>")
+                .tokenStrict(Byot.ENABLE)
+                .values(values1)
+                .tokens(tokens)
+                .returnTokens(true)
+                .build();
+        UpdateResponse updateResponse1 = skyflowClient.vault().update(updateRequest1);
+        System.out.println(updateResponse1);
+
+        HashMap<String, Object> values2 = new HashMap<>();
+        values2.put("<column_name_1>", "<column_value_1>");
+        values2.put("<column_name_2>", "<column_value_1>");
+
+        UpdateRequest updateRequest2 = UpdateRequest.builder()
+                .id("<your_skyflow_id")
+                .table("<table_name>")
+                .tokenStrict(Byot.DISABLE)
+                .values(values2)
+                .returnTokens(false)
+                .build();
+        UpdateResponse updateResponse2 = skyflowClient.vault("<your_vault_id_2>").update(updateRequest2);
+        System.out.println(updateResponse2);
+    }
+}