Merge pull request apache#11950 from [BEAM-8596]: Add SplunkIO transf…

…orm to write messages to Splunk

* [BEAM-8596]: Add SplunkIO transform to write messages to Splunk

* Use AutoValueSchema instead of custom Coder

* SplunkIO switch from builder to fluent factory pattern

* Build file change and switch to TimeDomain.PROCESSING_TIME

CHANGES.md

@@ -58,6 +58,7 @@
 
 * Support for X source added (Java/Python) ([BEAM-X](https://issues.apache.org/jira/browse/BEAM-X)).
 * Support for reading from Snowflake added (Java) ([BEAM-9722](https://issues.apache.org/jira/browse/BEAM-9722)).
+* Support for writing to Splunk added (Java) ([BEAM-8596](https://issues.apache.org/jira/browse/BEAM-8596)).
 
 ## New Features / Improvements
 

buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

@@ -392,6 +392,7 @@ class BeamModulePlugin implements Plugin<Project> {
  def google_cloud_core_version = "1.92.2"
  def google_cloud_spanner_version = "1.49.1"
  def google_cloud_datacatalog_version = "0.32.1"
+ def google_code_gson_version = "2.8.6"
  def google_http_clients_version = "1.34.0"
  def google_oauth_clients_version = "1.30.6"
  def grpc_version = "1.27.2"
@@ -480,7 +481,9 @@ class BeamModulePlugin implements Plugin<Project> {
  google_cloud_dataflow_java_proto_library_all: "com.google.cloud.dataflow:google-cloud-dataflow-java-proto-library-all:0.5.160304",
  google_cloud_datastore_v1_proto_client : "com.google.cloud.datastore:datastore-v1-proto-client:1.6.3",
  google_cloud_spanner : "com.google.cloud:google-cloud-spanner:$google_cloud_spanner_version",
+ google_code_gson : "com.google.code.gson:gson:$google_code_gson_version",
  google_http_client : "com.google.http-client:google-http-client:$google_http_clients_version",
+ google_http_client_apache_v2 : "com.google.http-client:google-http-client-apache-v2:$google_http_clients_version",
  google_http_client_jackson : "com.google.http-client:google-http-client-jackson:1.29.2",
  google_http_client_jackson2 : "com.google.http-client:google-http-client-jackson2:$google_http_clients_version",
  google_http_client_protobuf : "com.google.http-client:google-http-client-protobuf:$google_http_clients_version",

sdks/java/io/splunk/build.gradle

@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * License); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+plugins {
+ id 'org.apache.beam.module'
+}
+applyJavaNature(automaticModuleName: 'org.apache.beam.sdk.io.splunk')
+
+description = "Apache Beam :: SDKs :: Java :: IO :: Splunk"
+ext.summary = "IO to write events to Splunk Http Event Collector (HEC)"
+
+dependencies {
+ compile library.java.slf4j_api
+ compile library.java.google_api_client
+ compile library.java.google_http_client_apache_v2
+ compile library.java.google_code_gson
+ compile project(path: ":sdks:java:core", configuration: "shadow")
+ testCompile library.java.junit
+ testCompile group: 'org.mock-server', name: 'mockserver-junit-rule', version: '5.10.0'
+ testCompile group: 'org.mock-server', name: 'mockserver-client-java', version: '5.10.0'
+ testCompile group: 'org.junit.jupiter', name: 'junit-jupiter-api', version: '5.6.2'
+ testRuntimeOnly library.java.slf4j_jdk14
+ testRuntimeOnly project(path: ":runners:direct-java", configuration: "shadow")
+}