org.apache.beam.sdk.io.mongodb.MongoDbReadSchemaTransformConfiguration

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

Configuration class for the MongoDB Read transform.

See Also:

Constructor Details
- MongoDbReadSchemaTransformConfiguration
  
  public MongoDbReadSchemaTransformConfiguration()
Method Details
- getUri
  
  @SchemaFieldDescription("The connection URI for the MongoDB server.") public abstract String getUri()
- getDatabase
  
  @SchemaFieldDescription("The MongoDB database to read from.") public abstract String getDatabase()
- getCollection
  
  @SchemaFieldDescription("The MongoDB collection to read from.") public abstract String getCollection()
- getSchema
  
  @SchemaFieldDescription("The schema in which the data is encoded, defined with JSON-schema syntax (https://json-schema.org/).") public abstract String getSchema()
- getFilter
  
  @SchemaFieldDescription("An optional BSON filter to apply to the read. This should be a valid JSON string.") public abstract @Nullable String getFilter()
- getErrorHandling
  
  @SchemaFieldDescription("This option specifies whether and where to output rows that failed to be read.") public abstract @Nullable ErrorHandling getErrorHandling()
- validate
  
  public void validate()
- builder
  
  public static MongoDbReadSchemaTransformConfiguration.Builder builder()

Class MongoDbReadSchemaTransformConfiguration

Nested Class Summary