class ParquetReadFn[T, R] extends DoFn[ReadableFile, R]
- Source
- ParquetReadFn.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ParquetReadFn
- DoFn
- HasDisplayData
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ParquetReadFn(readSupportFactory: ReadSupportFactory[T], conf: SerializableConfiguration, projectionFn: SerializableFunction[T, R])
Type Members
- abstract class FinishBundleContext extends AnyRef
- Definition Classes
- DoFn
- abstract class OnTimerContext extends WindowedContext
- Definition Classes
- DoFn
- abstract class OnWindowExpirationContext extends WindowedContext
- Definition Classes
- DoFn
- abstract class ProcessContext extends WindowedContext
- Definition Classes
- DoFn
- abstract class StartBundleContext extends AnyRef
- Definition Classes
- DoFn
- abstract class WindowedContext extends AnyRef
- Definition Classes
- DoFn
Abstract Value Members
Concrete Value Members
- def getInitialRestriction(file: ReadableFile): OffsetRange
- Annotations
- @GetInitialRestriction()
- def getInputTypeDescriptor(): TypeDescriptor[ReadableFile]
- Definition Classes
- DoFn
- def getOutputTypeDescriptor(): TypeDescriptor[R]
- Definition Classes
- DoFn
- def getRestrictionCoder: Coder
- Annotations
- @GetRestrictionCoder()
- def getSize(file: ReadableFile, restriction: OffsetRange): Double
- Annotations
- @GetSize()
- def newTracker(restriction: OffsetRange): OffsetRangeTracker
- Annotations
- @NewTracker()
- def populateDisplayData(builder: Builder): Unit
- Definition Classes
- DoFn → HasDisplayData
- def processElement(file: ReadableFile, tracker: RestrictionTracker[OffsetRange, Long], out: OutputReceiver[R]): Unit
- Annotations
- @ProcessElement()
- def split(restriction: OffsetRange, output: OutputReceiver[OffsetRange], file: ReadableFile): Unit
- Annotations
- @SplitRestriction()
- def splitRowGroupsWithLimit(startGroup: Long, endGroup: Long, rowGroups: Seq[BlockMetaData]): Seq[OffsetRange]