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

Class PubsubLiteReadSchemaTransformProvider.PubsubLiteReadSchemaTransformConfiguration

java.lang.Object

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

Enclosing class:

PubsubLiteReadSchemaTransformProvider

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubsubLiteReadSchemaTransformProvider.PubsubLiteReadSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
PubsubLiteReadSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static PubsubLiteReadSchemaTransformProvider.PubsubLiteReadSchemaTransformConfiguration.Builder	builder()
abstract java.lang.String	getFormat()
abstract java.lang.String	getLocation()
abstract @Nullable java.lang.String	getProject()
abstract java.lang.String	getSchema()
abstract java.lang.String	getSubscriptionName()

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubLiteReadSchemaTransformConfiguration

public PubsubLiteReadSchemaTransformConfiguration()

Method Detail

getFormat

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

getSchema

@SchemaFieldDescription(value="The schema in which the data is encoded in the Kafka topic. For AVRO data, this is a schema defined with AVRO schema syntax (https://avro.apache.org/docs/1.10.2/spec.html#schemas). For JSON data, this is a schema defined with JSON-schema syntax (https://json-schema.org/).")
public abstract java.lang.String getSchema()

getProject

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

getSubscriptionName

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

getLocation

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

builder

public static PubsubLiteReadSchemaTransformProvider.PubsubLiteReadSchemaTransformConfiguration.Builder builder()