This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 83df746 Bump default Pubsub timeout to 60 seconds (#11985)
add db00d86 Merge pull request #11950 from [BEAM-8596]: Add SplunkIO
transform to write messages to Splunk
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 +
sdks/java/io/{thrift => splunk}/build.gradle | 38 +-
.../beam/sdk/io/splunk/HttpEventPublisher.java | 346 ++++++++++++++++++
.../org/apache/beam/sdk/io/splunk/SplunkEvent.java | 162 +++++++++
.../beam/sdk/io/splunk/SplunkEventWriter.java | 395 +++++++++++++++++++++
.../org/apache/beam/sdk/io/splunk/SplunkIO.java | 312 ++++++++++++++++
.../beam/sdk/io/splunk/SplunkWriteError.java | 103 ++++++
.../apache/beam/sdk/io/splunk}/package-info.java | 8 +-
.../beam/sdk/io/splunk/HttpEventPublisherTest.java | 160 +++++++++
.../apache/beam/sdk/io/splunk/SplunkEventTest.java | 70 ++++
.../beam/sdk/io/splunk/SplunkEventWriterTest.java | 277 +++++++++++++++
.../apache/beam/sdk/io/splunk/SplunkIOTest.java | 197 ++++++++++
.../beam/sdk/io/splunk/SplunkWriteErrorTest.java | 58 +++
settings.gradle | 1 +
15 files changed, 2100 insertions(+), 31 deletions(-)
copy sdks/java/io/{thrift => splunk}/build.gradle (52%)
create mode 100644
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/HttpEventPublisher.java
create mode 100644
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEvent.java
create mode 100644
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEventWriter.java
create mode 100644
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkIO.java
create mode 100644
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkWriteError.java
copy sdks/java/io/{thrift/src/main/java/org/apache/beam/sdk/io/thrift =>
splunk/src/main/java/org/apache/beam/sdk/io/splunk}/package-info.java (84%)
create mode 100644
sdks/java/io/splunk/src/test/java/org/apache/beam/sdk/io/splunk/HttpEventPublisherTest.java
create mode 100644
sdks/java/io/splunk/src/test/java/org/apache/beam/sdk/io/splunk/SplunkEventTest.java
create mode 100644
sdks/java/io/splunk/src/test/java/org/apache/beam/sdk/io/splunk/SplunkEventWriterTest.java
create mode 100644
sdks/java/io/splunk/src/test/java/org/apache/beam/sdk/io/splunk/SplunkIOTest.java
create mode 100644
sdks/java/io/splunk/src/test/java/org/apache/beam/sdk/io/splunk/SplunkWriteErrorTest.java
