B C D E F G H I N O P S T V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
B
- Builder() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
- Builder() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkWriteError.Builder
C
- checkClientTrusted(X509Certificate[], String) - Method in class org.apache.beam.sdk.io.splunk.CustomX509TrustManager
- checkServerTrusted(X509Certificate[], String) - Method in class org.apache.beam.sdk.io.splunk.CustomX509TrustManager
- create() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Creates a
SplunkEventobject. - create() - Method in class org.apache.beam.sdk.io.splunk.SplunkWriteError.Builder
-
Builds a
SplunkWriteErrorobject. - CustomX509TrustManager - Class in org.apache.beam.sdk.io.splunk
-
A Custom X509TrustManager that trusts a user provided CA and default CA's.
- CustomX509TrustManager(X509Certificate) - Constructor for class org.apache.beam.sdk.io.splunk.CustomX509TrustManager
D
- decode(InputStream) - Method in class org.apache.beam.sdk.io.splunk.SplunkEventCoder
E
- encode(SplunkEvent, OutputStream) - Method in class org.apache.beam.sdk.io.splunk.SplunkEventCoder
- event() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent
- expand(PCollection<SplunkEvent>) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
F
- fields() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent
G
- getAcceptedIssuers() - Method in class org.apache.beam.sdk.io.splunk.CustomX509TrustManager
- getCoderProvider() - Static method in class org.apache.beam.sdk.io.splunk.SplunkEventCoder
- getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.io.splunk.SplunkEventCoder
H
- host() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent
I
- index() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent
N
- newBuilder() - Static method in class org.apache.beam.sdk.io.splunk.SplunkEvent
-
Provides a builder for creating
SplunkEventobjects. - newBuilder() - Static method in class org.apache.beam.sdk.io.splunk.SplunkWriteError
-
Provides a builder for creating
SplunkWriteErrorobjects.
O
- of() - Static method in class org.apache.beam.sdk.io.splunk.SplunkEventCoder
- org.apache.beam.sdk.io.splunk - package org.apache.beam.sdk.io.splunk
-
Transforms for writing events to Splunk's Http Event Collector (HEC).
P
- payload() - Method in class org.apache.beam.sdk.io.splunk.SplunkWriteError
S
- source() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent
- sourceType() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent
- SplunkEvent - Class in org.apache.beam.sdk.io.splunk
-
A
SplunkEventdescribes a single payload sent to Splunk's Http Event Collector (HEC) endpoint. - SplunkEvent() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkEvent
- SplunkEvent.Builder - Class in org.apache.beam.sdk.io.splunk
-
A builder class for creating a
SplunkEvent. - SplunkEventCoder - Class in org.apache.beam.sdk.io.splunk
-
A
CoderforSplunkEventobjects. - SplunkEventCoder() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkEventCoder
- SplunkIO - Class in org.apache.beam.sdk.io.splunk
-
An unbounded sink for Splunk's Http Event Collector (HEC).
- SplunkIO.Write - Class in org.apache.beam.sdk.io.splunk
-
Class
SplunkIO.Writeprovides aPTransformthat allows writingSplunkEventrecords into a Splunk HTTP Event Collector end-point using HTTP POST requests. - SplunkWriteError - Class in org.apache.beam.sdk.io.splunk
-
A class for capturing errors that occur while writing
SplunkEventto Splunk's Http Event Collector (HEC) end point. - SplunkWriteError() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkWriteError
- SplunkWriteError.Builder - Class in org.apache.beam.sdk.io.splunk
-
A builder class for creating a
SplunkWriteError. - statusCode() - Method in class org.apache.beam.sdk.io.splunk.SplunkWriteError
- statusMessage() - Method in class org.apache.beam.sdk.io.splunk.SplunkWriteError
T
- time() - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent
V
- verifyDeterministic() - Method in class org.apache.beam.sdk.io.splunk.SplunkEventCoder
W
- withBatchCount(Integer) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Sets batchCount for sending multiple events in a single request to the HEC.
- withBatchCount(ValueProvider<Integer>) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Same as
SplunkIO.Write.withBatchCount(Integer)but withValueProvider. - withDisableCertificateValidation(Boolean) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Disables ssl certificate validation.
- withDisableCertificateValidation(ValueProvider<Boolean>) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Same as
SplunkIO.Write.withDisableCertificateValidation(Boolean)but withValueProvider. - withEnableBatchLogs(Boolean) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Method to enable batch logs.
- withEnableBatchLogs(ValueProvider<Boolean>) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Same as
SplunkIO.Write.withEnableBatchLogs(ValueProvider)but without aValueProvider. - withEnableGzipHttpCompression(Boolean) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Method to specify if HTTP requests sent to Splunk should be GZIP encoded.
- withEnableGzipHttpCompression(ValueProvider<Boolean>) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Same as
SplunkIO.Write.withEnableGzipHttpCompression(ValueProvider)but without aValueProvider. - withEvent(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Assigns the event payload to be sent to the HEC endpoint.
- withFields(JsonObject) - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Assigns fields value to the event metadata.
- withHost(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Assigns host value to the event metadata.
- withIndex(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Assigns index value to the event metadata.
- withParallelism(Integer) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Sets the number of parallel http client connections to the HEC.
- withParallelism(ValueProvider<Integer>) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Same as
SplunkIO.Write.withBatchCount(Integer)but withValueProvider. - withPayload(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkWriteError.Builder
-
Assigns the payload to be used for reprocessing.
- withRootCaCertificatePath(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Method to set the root CA certificate.
- withRootCaCertificatePath(ValueProvider<String>) - Method in class org.apache.beam.sdk.io.splunk.SplunkIO.Write
-
Same as
SplunkIO.Write.withRootCaCertificatePath(ValueProvider)but without aValueProvider. - withSource(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Assigns source value to the event metadata.
- withSourceType(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Assigns sourceType value to the event metadata.
- withStatusCode(Integer) - Method in class org.apache.beam.sdk.io.splunk.SplunkWriteError.Builder
-
Assigns a return status code to assist with debugging.
- withStatusMessage(String) - Method in class org.apache.beam.sdk.io.splunk.SplunkWriteError.Builder
-
Assigns a return status message to assist with debugging.
- withTime(Long) - Method in class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
-
Assigns time value to the event metadata.
- write(String, String) - Static method in class org.apache.beam.sdk.io.splunk.SplunkIO
-
Write to Splunk's Http Event Collector (HEC).
- write(ValueProvider<String>, ValueProvider<String>) - Static method in class org.apache.beam.sdk.io.splunk.SplunkIO
-
Same as
SplunkIO.write(String, String)but withValueProvider. - Write() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkIO.Write
All Classes All Packages