You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jo...@apache.org on 2022/12/22 21:57:43 UTC
[beam] branch master updated (9810ff82b75 -> 28afd035271)

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

johncasey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 9810ff82b75 Implement PubsubWriteSchemaTransformProvider (#24443)
     add 28afd035271 [CdapIO] Complete examples for CDAP Hubspot plugins  (#24568)

No new revisions were added by this update.

Summary of changes:
 examples/java/cdap/README.md                       |   4 +-
 examples/java/cdap/hubspot/build.gradle            | 112 ++++++++++++++++
 .../cdap/hubspot/CdapHubspotStreamingToTxt.java    | 146 +++++++++++++++++++++
 .../complete/cdap/hubspot/CdapHubspotToTxt.java    | 141 ++++++++++++++++++++
 .../beam/examples/complete/cdap/hubspot/README.md  | 110 ++++++++++++++++
 .../complete/cdap/hubspot/TxtToCdapHubspot.java    | 128 ++++++++++++++++++
 .../cdap/hubspot/options/CdapHubspotOptions.java   |  46 +++++++
 .../hubspot/options/CdapHubspotSinkOptions.java    |  44 +++++++
 .../hubspot/options/CdapHubspotSourceOptions.java  |  36 +++++
 .../options/CdapHubspotStreamingSourceOptions.java |  38 ++++++
 .../cdap/hubspot/options/package-info.java         |  20 +++
 .../complete/cdap/hubspot/package-info.java        |  20 +++
 .../hubspot/transforms/FormatInputTransform.java   |  94 +++++++++++++
 .../hubspot/transforms/FormatOutputTransform.java  |  53 ++++++++
 .../cdap/hubspot/transforms/package-info.java      |  20 +++
 .../cdap/hubspot/utils/GetOffsetUtils.java         |  74 +++++++++++
 .../utils/PluginConfigOptionsConverter.java        |  53 ++++++++
 .../complete/cdap/hubspot/utils/package-info.java  |  20 +++
 .../example-txt-to-cdap-hubspot-companies.txt      |  20 +++
 .../complete/cdap/utils/JsonElementCoder.java      |  49 +++++++
 settings.gradle.kts                                |   1 +
 21 files changed, 1227 insertions(+), 2 deletions(-)
 create mode 100644 examples/java/cdap/hubspot/build.gradle
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/CdapHubspotStreamingToTxt.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/CdapHubspotToTxt.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/README.md
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/TxtToCdapHubspot.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotOptions.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotSinkOptions.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotSourceOptions.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotStreamingSourceOptions.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/package-info.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/package-info.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/transforms/FormatInputTransform.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/transforms/FormatOutputTransform.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/transforms/package-info.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/utils/GetOffsetUtils.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/utils/PluginConfigOptionsConverter.java
 create mode 100644 examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/utils/package-info.java
 create mode 100644 examples/java/cdap/hubspot/src/test/resources/example-txt-to-cdap-hubspot-companies.txt
 create mode 100644 examples/java/cdap/src/main/java/org/apache/beam/examples/complete/cdap/utils/JsonElementCoder.java