Class AvroSchemaInformationProvider
java.lang.Object
org.apache.beam.sdk.extensions.avro.schemas.utils.AvroSchemaInformationProvider
- All Implemented Interfaces:
SchemaInformationProvider
@AutoService(SchemaInformationProvider.class)
public class AvroSchemaInformationProvider
extends Object
implements SchemaInformationProvider
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiongetConvertedSchemaInformation
(Schema inputSchema, TypeDescriptor<T> outputType)
-
Constructor Details
-
AvroSchemaInformationProvider
public AvroSchemaInformationProvider()
-
-
Method Details
-
getConvertedSchemaInformation
@Nullable public <T> ConvertHelpers.ConvertedSchemaInformation<T> getConvertedSchemaInformation(Schema inputSchema, TypeDescriptor<T> outputType) - Specified by:
getConvertedSchemaInformation
in interfaceSchemaInformationProvider
-