@DefaultSchema(value=AutoValueSchema.class) public abstract class PubsubWriteSchemaTransformConfiguration extends java.lang.Object
Internal only: This class is actively being worked on, and it will likely change. We provide no backwards compatibility guarantees, and it should not be implemented outside the Beam repository.
Modifier and Type | Class and Description |
---|---|
static class |
PubsubWriteSchemaTransformConfiguration.Builder |
Constructor and Description |
---|
PubsubWriteSchemaTransformConfiguration() |
Modifier and Type | Method and Description |
---|---|
static PubsubWriteSchemaTransformConfiguration.Builder |
builder() |
abstract java.lang.String |
getFormat() |
abstract java.lang.String |
getTopic() |
public PubsubWriteSchemaTransformConfiguration()
@SchemaFieldDescription(value="The encoding format for the data stored in Pubsub. Valid options are: AVRO,JSON") public abstract java.lang.String getFormat()
@SchemaFieldDescription(value="The name of the topic to write data to. Format: projects/${PROJECT}/topics/${TOPIC}") public abstract java.lang.String getTopic()
public static PubsubWriteSchemaTransformConfiguration.Builder builder()