Package org.apache.beam.sdk.io
Class AvroSchemaIOProvider
- java.lang.Object
-
- org.apache.beam.sdk.io.AvroSchemaIOProvider
-
- All Implemented Interfaces:
SchemaIOProvider
@Internal @AutoService(SchemaIOProvider.class) public class AvroSchemaIOProvider extends java.lang.Object implements SchemaIOProvider
An implementation ofSchemaIOProvider
for reading and writing Avro files withAvroIO
.
-
-
Constructor Summary
Constructors Constructor Description AvroSchemaIOProvider()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Schema
configurationSchema()
Returns the expected schema of the configuration object.org.apache.beam.sdk.io.AvroSchemaIOProvider.AvroSchemaIO
from(java.lang.String location, Row configuration, Schema dataSchema)
Produce a SchemaIO given a String representing the data's location, the schema of the data that resides there, and some IO-specific configuration object.java.lang.String
identifier()
Returns an id that uniquely represents this IO.PCollection.IsBounded
isBounded()
boolean
requiresDataSchema()
Indicates whether the dataSchema value is necessary.
-
-
-
Method Detail
-
identifier
public java.lang.String identifier()
Returns an id that uniquely represents this IO.- Specified by:
identifier
in interfaceSchemaIOProvider
-
configurationSchema
public Schema configurationSchema()
Returns the expected schema of the configuration object. Note this is distinct from the schema of the data source itself. No configuration expected for Avro.- Specified by:
configurationSchema
in interfaceSchemaIOProvider
-
from
public org.apache.beam.sdk.io.AvroSchemaIOProvider.AvroSchemaIO from(java.lang.String location, Row configuration, Schema dataSchema)
Produce a SchemaIO given a String representing the data's location, the schema of the data that resides there, and some IO-specific configuration object.- Specified by:
from
in interfaceSchemaIOProvider
-
requiresDataSchema
public boolean requiresDataSchema()
Description copied from interface:SchemaIOProvider
Indicates whether the dataSchema value is necessary.- Specified by:
requiresDataSchema
in interfaceSchemaIOProvider
-
isBounded
public PCollection.IsBounded isBounded()
- Specified by:
isBounded
in interfaceSchemaIOProvider
-
-