@AutoService(value=org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider.class) public class PubsubLiteWriteSchemaTransformProvider extends org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration>
Modifier and Type | Class and Description |
---|---|
static class |
PubsubLiteWriteSchemaTransformProvider.ErrorCounterFn |
static class |
PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration |
static class |
PubsubLiteWriteSchemaTransformProvider.SetUuidFromPubSubMessage |
Modifier and Type | Field and Description |
---|---|
static org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.Row> |
ERROR_TAG |
static org.apache.beam.sdk.values.TupleTag<com.google.cloud.pubsublite.proto.PubSubMessage> |
OUTPUT_TAG |
static java.util.Set<java.lang.String> |
SUPPORTED_FORMATS |
static java.lang.String |
SUPPORTED_FORMATS_STR |
Constructor and Description |
---|
PubsubLiteWriteSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
protected @UnknownKeyFor @NonNull @Initialized java.lang.Class<PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration> |
configurationClass() |
@UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.schemas.transforms.SchemaTransform |
from(PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration configuration) |
static org.apache.beam.sdk.transforms.SerializableFunction<org.apache.beam.sdk.values.Row,byte[]> |
getRowToRawBytesFunction(java.lang.String rowFieldName) |
static org.apache.beam.sdk.schemas.Schema |
getSchemaWithoutAttributes(org.apache.beam.sdk.schemas.Schema inputSchema,
java.util.List<java.lang.String> attributes) |
@UnknownKeyFor @NonNull @Initialized java.lang.String |
identifier() |
@UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> |
inputCollectionNames() |
@UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> |
outputCollectionNames() |
configurationSchema, dependencies, from
public static final java.lang.String SUPPORTED_FORMATS_STR
public static final java.util.Set<java.lang.String> SUPPORTED_FORMATS
public static final org.apache.beam.sdk.values.TupleTag<com.google.cloud.pubsublite.proto.PubSubMessage> OUTPUT_TAG
public static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.Row> ERROR_TAG
public PubsubLiteWriteSchemaTransformProvider()
protected @UnknownKeyFor @NonNull @Initialized java.lang.Class<PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration> configurationClass()
configurationClass
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration>
public @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.schemas.transforms.SchemaTransform from(PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration configuration)
from
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<PubsubLiteWriteSchemaTransformProvider.PubsubLiteWriteSchemaTransformConfiguration>
public static org.apache.beam.sdk.schemas.Schema getSchemaWithoutAttributes(org.apache.beam.sdk.schemas.Schema inputSchema, java.util.List<java.lang.String> attributes)
public static org.apache.beam.sdk.transforms.SerializableFunction<org.apache.beam.sdk.values.Row,byte[]> getRowToRawBytesFunction(java.lang.String rowFieldName)
public @UnknownKeyFor @NonNull @Initialized java.lang.String identifier()
public @UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> inputCollectionNames()
public @UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> outputCollectionNames()