This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 8a43f5e5b50 Merge pull request #37286 Fix link due to trailing slashes.
add 52e284748f2 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#37367)
add e7c80cd9306 Add more info to CHANGES on logical type issue (#37368)
add 84b467b45a5 Add Datadog IO (#37319)
add f1e4b7468b6 Bump github.com/linkedin/goavro/v2 from 2.14.1 to 2.15.0
in /sdks (#37366)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 1 +
...l => beam_PreCommit_Java_Datadog_IO_Direct.yml} | 22 +-
CHANGES.md | 12 +-
build.gradle.kts | 1 +
sdks/go.mod | 4 +-
sdks/go.sum | 8 +-
sdks/java/io/{splunk => datadog}/build.gradle | 41 +-
.../apache/beam/sdk/io/datadog/DatadogEvent.java | 97 ++++
.../beam/sdk/io/datadog/DatadogEventCoder.java | 94 ++++
.../beam/sdk/io/datadog/DatadogEventPublisher.java | 330 ++++++++++++
.../sdk/io/datadog/DatadogEventSerializer.java | 45 ++
.../beam/sdk/io/datadog/DatadogEventWriter.java | 521 +++++++++++++++++++
.../org/apache/beam/sdk/io/datadog/DatadogIO.java | 236 +++++++++
.../beam/sdk/io/datadog/DatadogWriteError.java} | 53 +-
.../sdk/io/datadog/DatadogWriteErrorCoder.java | 88 ++++
.../apache/beam/sdk/io/datadog}/package-info.java | 16 +-
.../beam/sdk/io/datadog/DatadogEventCoderTest.java | 65 +++
.../sdk/io/datadog/DatadogEventPublisherTest.java | 176 +++++++
.../sdk/io/datadog/DatadogEventSerializerTest.java | 95 ++++
.../beam/sdk/io/datadog/DatadogEventTest.java | 73 +++
.../sdk/io/datadog/DatadogEventWriterTest.java | 566 +++++++++++++++++++++
.../apache/beam/sdk/io/datadog/DatadogIOTest.java | 172 +++++++
.../sdk/io/datadog/DatadogWriteErrorCoderTest.java | 61 +++
.../beam/sdk/io/datadog/DatadogWriteErrorTest.java | 66 +++
settings.gradle.kts | 1 +
25 files changed, 2755 insertions(+), 89 deletions(-)
copy .github/workflows/{beam_PreCommit_Java_Csv_IO_Direct.yml =>
beam_PreCommit_Java_Datadog_IO_Direct.yml} (86%)
copy sdks/java/io/{splunk => datadog}/build.gradle (71%)
create mode 100644
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogEvent.java
create mode 100644
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogEventCoder.java
create mode 100644
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogEventPublisher.java
create mode 100644
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogEventSerializer.java
create mode 100644
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogEventWriter.java
create mode 100644
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogIO.java
copy
sdks/java/io/{splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkWriteError.java
=>
datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogWriteError.java}
(56%)
create mode 100644
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogWriteErrorCoder.java
copy sdks/java/{core/src/main/java/org/apache/beam/sdk/io/range =>
io/datadog/src/main/java/org/apache/beam/sdk/io/datadog}/package-info.java (64%)
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogEventCoderTest.java
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogEventPublisherTest.java
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogEventSerializerTest.java
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogEventTest.java
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogEventWriterTest.java
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogIOTest.java
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogWriteErrorCoderTest.java
create mode 100644
sdks/java/io/datadog/src/test/java/org/apache/beam/sdk/io/datadog/DatadogWriteErrorTest.java
