org.apache.beam.sdk.io.gcp.pubsublite

Class PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsublite.PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration

Enclosing class:

PubsubLiteWriteSchemaTransformProvider

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
PubsubLiteWriteSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration.Builder	builder()
abstract java.lang.String	getFormat()
abstract java.lang.String	getLocation()
abstract java.lang.String	getProject()
abstract java.lang.String	getTopicName()

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubLiteWriteSchemaTransformConfiguration

public PubsubLiteWriteSchemaTransformConfiguration()

Method Detail

getProject

@SchemaFieldDescription(value="The GCP project where the Pubsub Lite reservation resides. This can be a project number of a project ID.")
public abstract java.lang.String getProject()

getLocation

@SchemaFieldDescription(value="The region or zone where the Pubsub Lite reservation resides.")
public abstract java.lang.String getLocation()

getTopicName

@SchemaFieldDescription(value="The name of the topic to publish data into. This will be concatenated with the project and location parameters to build a full topic path.")
public abstract java.lang.String getTopicName()

getFormat

@SchemaFieldDescription(value="The encoding format for the data stored in Pubsub Lite. Valid options are: JSON,AVRO")
public abstract java.lang.String getFormat()

builder

public static PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration.Builder builder()