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
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
    ParquetAvroFileOperationsFileOperations
    Annotations
    @SuppressWarnings() @Override()
  3. final def iterator(resourceId: ResourceId): Iterator[ValueT]
    Definition Classes
    FileOperations
  4. def populateDisplayData(builder: Builder): Unit
    Definition Classes
    ParquetAvroFileOperationsFileOperations → 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]