class ParquetAvroFileOperations[ValueT] extends FileOperations[ValueT]
org.apache.beam.sdk.extensions.smb.FileOperations
implementation for Parquet files with
Avro records.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ParquetAvroFileOperations
- FileOperations
- HasDisplayData
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- def createWriter(resourceId: ResourceId): Writer[ValueT]
- Definition Classes
- FileOperations
- def getCoder(): Coder[ValueT]
- Definition Classes
- ParquetAvroFileOperations → FileOperations
- Annotations
- @SuppressWarnings() @Override()
- final def iterator(resourceId: ResourceId): Iterator[ValueT]
- Definition Classes
- FileOperations
- def populateDisplayData(builder: Builder): Unit
- Definition Classes
- ParquetAvroFileOperations → FileOperations → HasDisplayData
- Annotations
- @Override()
- def withCompression(compression: CompressionCodecName): ParquetAvroFileOperations[ValueT]
- def withConfiguration(configuration: Configuration): ParquetAvroFileOperations[ValueT]
- def withFilterPredicate(filterPredicate: FilterPredicate): ParquetAvroFileOperations[ValueT]
- def withProjection(projection: Schema): ParquetAvroFileOperations[ValueT]