Package org.apache.beam.sdk.io.mongodb

Class MongoDbWriteSchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.mongodb.MongoDbWriteSchemaTransformConfiguration

All Implemented Interfaces:

Serializable

@DefaultSchema(AutoValueSchema.class)
public abstract class MongoDbWriteSchemaTransformConfiguration
extends Object
implements Serializable

Configuration class for the MongoDB Write transform.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MongoDbWriteSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
MongoDbWriteSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method	Description
static MongoDbWriteSchemaTransformConfiguration.Builder	builder()
abstract @Nullable Long	getBatchSize()
abstract String	getCollection()
abstract String	getDatabase()
abstract @Nullable ErrorHandling	getErrorHandling()
abstract String	getUri()
void	validate()

Methods inherited from class java.lang.Object

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

Constructor Details

MongoDbWriteSchemaTransformConfiguration

public MongoDbWriteSchemaTransformConfiguration()

Method Details

getUri

@SchemaFieldDescription("The connection URI for the MongoDB server.")
public abstract String getUri()

getDatabase

@SchemaFieldDescription("The MongoDB database to write to.")
public abstract String getDatabase()

getCollection

@SchemaFieldDescription("The MongoDB collection to write to.")
public abstract String getCollection()

getBatchSize

@SchemaFieldDescription("The number of documents to include in each batch write.")
public abstract @Nullable Long getBatchSize()

getErrorHandling

@SchemaFieldDescription("This option specifies whether and where to output unwritable rows. Note: Error handling is currently limited to data conversion failures before sending to the MongoDB driver, as the underlying MongoDbIO does not yet support dead-letter queues for write failures.")
public abstract @Nullable ErrorHandling getErrorHandling()

validate

public void validate()

builder

public static MongoDbWriteSchemaTransformConfiguration.Builder builder()