Package org.apache.beam.sdk.io.datadog

Class DatadogWriteSchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.datadog.DatadogWriteSchemaTransformConfiguration

@DefaultSchema(AutoValueSchema.class)
public abstract class DatadogWriteSchemaTransformConfiguration
extends Object

Configuration for writing to Datadog.

This class is meant to be used with DatadogWriteSchemaTransformProvider.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DatadogWriteSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
DatadogWriteSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method	Description
static DatadogWriteSchemaTransformConfiguration.Builder	builder()	Instantiates a DatadogWriteSchemaTransformConfiguration.Builder instance.
abstract String	getApiKey()
abstract Integer	getBatchCount()
abstract ErrorHandling	getErrorHandling()
abstract Long	getMaxBufferSize()
abstract Integer	getMinBatchCount()
abstract Integer	getParallelism()
abstract String	getUrl()
void	validate()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DatadogWriteSchemaTransformConfiguration

public DatadogWriteSchemaTransformConfiguration()

Method Details

validate

public void validate()

builder

public static DatadogWriteSchemaTransformConfiguration.Builder builder()

Instantiates a DatadogWriteSchemaTransformConfiguration.Builder instance.

getUrl

@SchemaFieldDescription("The Datadog API URL.")
public abstract String getUrl()

getApiKey

@SchemaFieldDescription("The Datadog API key.")
public abstract String getApiKey()

getMinBatchCount

@SchemaFieldDescription("The minimum number of events to batch together for each write.")
@Nullable
public abstract Integer getMinBatchCount()

getBatchCount

@SchemaFieldDescription("The number of events to batch together for each write.")
@Nullable
public abstract Integer getBatchCount()

getMaxBufferSize

@SchemaFieldDescription("The maximum buffer size in bytes.")
@Nullable
public abstract Long getMaxBufferSize()

getParallelism

@SchemaFieldDescription("The degree of parallelism for writing.")
@Nullable
public abstract Integer getParallelism()

getErrorHandling

@SchemaFieldDescription("Specifies how to handle errors.")
@Nullable
public abstract ErrorHandling getErrorHandling()