You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yh...@apache.org on 2022/12/27 15:17:01 UTC
[beam] branch master updated (ffdd8d47b78 -> 59946441269)
This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from ffdd8d47b78 [Playground] Python multifile examples (#24751)
add 59946441269 [CdapIO] Complete examples for CDAP Salesforce plugins (#24567)
No new revisions were added by this update.
Summary of changes:
examples/java/cdap/README.md | 2 +-
examples/java/cdap/hubspot/build.gradle | 2 +-
.../beam/examples/complete/cdap/hubspot/README.md | 14 +-
.../cdap/{servicenow => salesforce}/build.gradle | 17 ++-
.../salesforce/CdapSalesforceStreamingToTxt.java | 154 +++++++++++++++++++++
.../cdap/salesforce/CdapSalesforceToTxt.java | 137 ++++++++++++++++++
.../examples/complete/cdap/salesforce/README.md | 123 ++++++++++++++++
.../cdap/salesforce/TxtToCdapSalesforce.java | 151 ++++++++++++++++++++
.../salesforce/options/CdapSalesforceOptions.java | 66 +++++++++
.../options/CdapSalesforceSinkOptions.java | 86 ++++++++++++
.../options/CdapSalesforceSourceOptions.java | 44 ++++++
.../CdapSalesforceStreamingSourceOptions.java | 45 ++++++
.../cdap/salesforce/options/package-info.java | 20 +++
.../complete/cdap/salesforce/package-info.java | 20 +++
.../transforms/FormatInputTransform.java | 106 ++++++++++++++
.../transforms/FormatOutputTransform.java | 54 ++++++++
.../cdap/salesforce/transforms/package-info.java | 20 +++
.../cdap/salesforce/utils/CsvRecordCoder.java | 48 +++++++
.../cdap/salesforce/utils/GetOffsetUtils.java | 80 +++++++++++
.../utils/PluginConfigOptionsConverter.java | 100 +++++++++++++
.../cdap/salesforce/utils/package-info.java | 20 +++
.../example-txt-to-cdap-salesforce-custom.txt | 20 +++
examples/java/cdap/servicenow/build.gradle | 2 +-
.../examples/complete/cdap/servicenow/README.md | 6 +-
examples/java/cdap/zendesk/build.gradle | 2 +-
.../beam/examples/complete/cdap/zendesk/README.md | 6 +-
settings.gradle.kts | 1 +
27 files changed, 1322 insertions(+), 24 deletions(-)
copy examples/java/cdap/{servicenow => salesforce}/build.gradle (87%)
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/CdapSalesforceStreamingToTxt.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/CdapSalesforceToTxt.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/README.md
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/TxtToCdapSalesforce.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceOptions.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceSinkOptions.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceSourceOptions.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceStreamingSourceOptions.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/package-info.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/package-info.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/transforms/FormatInputTransform.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/transforms/FormatOutputTransform.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/transforms/package-info.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/CsvRecordCoder.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/GetOffsetUtils.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/PluginConfigOptionsConverter.java
create mode 100644 examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/package-info.java
create mode 100644 examples/java/cdap/salesforce/src/test/resources/example-txt-to-cdap-salesforce-custom.txt