[incubator-gobblin] branch master updated: [GOBBLIN-995] Add function to instantiate the BulkConnection in SFDC connector[]

[hutran]

This is an automated email from the ASF dual-hosted git repository.

hutran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 278a1c1  [GOBBLIN-995] Add function to instantiate the BulkConnection 
in SFDC connector[]
278a1c1 is described below

commit 278a1c1ec609ffc2b0f9890c92786072dae8af82
Author: Alex Li <al...@linkedin.com>
AuthorDate: Thu Dec 5 09:34:44 2019 -0800

    [GOBBLIN-995] Add function to instantiate the BulkConnection in SFDC 
connector[]
    
    Closes #2840 from arekusuri/DSS-23689-add-
    bulkconnection-function
---
 .../org/apache/gobblin/salesforce/SalesforceExtractor.java     | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
 
b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
index c665b1a..b0d444c 100644
--- 
a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
+++ 
b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
@@ -696,7 +696,7 @@ public class SalesforceExtractor extends RestApiExtractor {
       config.setRestEndpoint(restEndpoint);
 
 
-      this.bulkConnection = new BulkConnection(config);
+      this.bulkConnection = getBulkConnection(config);
       success = true;
     } catch (RuntimeException e) {
       throw new RuntimeException("Failed to connect to salesforce bulk api; 
error - " + e, e);
@@ -705,6 +705,14 @@ public class SalesforceExtractor extends RestApiExtractor {
   }
 
   /**
+   * get BulkConnection instance
+   * @return
+   */
+  public BulkConnection getBulkConnection(ConnectorConfig config) throws 
AsyncApiException {
+    return new BulkConnection(config);
+  }
+
+  /**
    * Get Record set using salesforce specific API(Bulk API)
    * @param entity/tablename
    * @param predicateList of all predicate conditions