c

org.apache.beam.sdk.extensions.smb

ParquetAvroFileOperations

class ParquetAvroFileOperations[ValueT] extends FileOperations[ValueT]

org.apache.beam.sdk.extensions.smb.FileOperations implementation for Parquet files with Avro records.

Source
ParquetAvroFileOperations.java
Linear Supertypes
FileOperations[ValueT], HasDisplayData, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ParquetAvroFileOperations
  2. FileOperations
  3. HasDisplayData
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def createWriter(resourceId: ResourceId): Writer[ValueT]
    Definition Classes
    FileOperations
  2. def getCoder(): Coder[ValueT]
    Definition Classes
    ParquetAvroFileOperations → FileOperations
    Annotations
    @SuppressWarnings() @Override()
  3. final def iterator(resourceId: ResourceId): Iterator[ValueT]
    Definition Classes
    FileOperations
  4. def populateDisplayData(builder: Builder): Unit
    Definition Classes
    ParquetAvroFileOperations → FileOperations → HasDisplayData
    Annotations
    @Override()
  5. def withCompression(compression: CompressionCodecName): ParquetAvroFileOperations[ValueT]
  6. def withConfiguration(configuration: Configuration): ParquetAvroFileOperations[ValueT]
  7. def withFilterPredicate(filterPredicate: FilterPredicate): ParquetAvroFileOperations[ValueT]
  8. def withProjection(projection: Schema): ParquetAvroFileOperations[ValueT]