@DefaultAnnotation(value=org.checkerframework.checker.nullness.qual.NonNull.class) @Experimental(value=EXTENSION)
See: Description
| Interface | Description |
|---|---|
| AvroIO.RecordFormatter<ElementT> | Deprecated
Users can achieve the same by providing this transform in a
ParDo before using write in AvroIO AvroIO.write(Class). |
| AvroSink.DatumWriterFactory<T> | |
| AvroSource.DatumReaderFactory<T> |
| Class | Description |
|---|---|
| AvroIO |
PTransforms for reading and writing Avro files. |
| AvroIO.Parse<T> | |
| AvroIO.ParseAll<T> | Deprecated
See
AvroIO.parseAllGenericRecords(SerializableFunction) for details. |
| AvroIO.ParseFiles<T> | |
| AvroIO.Read<T> |
Implementation of
AvroIO.read(java.lang.Class<T>) and AvroIO.readGenericRecords(org.apache.avro.Schema). |
| AvroIO.ReadAll<T> | Deprecated
See
AvroIO.readAll(Class) for details. |
| AvroIO.ReadFiles<T> |
Implementation of
AvroIO.readFiles(java.lang.Class<T>). |
| AvroIO.Sink<ElementT> | |
| AvroIO.TypedWrite<UserT,DestinationT,OutputT> |
Implementation of
AvroIO.write(java.lang.Class<T>). |
| AvroIO.Write<T> |
This class is used as the default return value of
AvroIO.write(java.lang.Class<T>) |
| AvroSchemaIOProvider |
An implementation of
SchemaIOProvider for reading and writing Avro files with AvroIO. |
| AvroSink<UserT,DestinationT,OutputT> |
A
FileBasedSink for Avro files. |
| AvroSource<T> |
Do not use in pipelines directly: most users should use
AvroIO.Read. |
| AvroSource.AvroReader<T> |
A
BlockBasedReader for reading blocks from Avro files. |
| DynamicAvroDestinations<UserT,DestinationT,OutputT> |
A specialization of
FileBasedSink.DynamicDestinations for AvroIO. |