The Internals of Apache Beam
Home
Products
Product A Product B Product C
Services
Service A Service B Service C
Resources
Resource A Resource B Resource C
Download

Apache Beam

    • Introduction
    • PCollection
    • PTransform
      • GroupByKey
      • MapElements
      • ParDo
        • DoFn
        • WindowedContext
        • ProcessContext
    • Pipeline
      • TransformHierarchy
        • Node
      • PipelineVisitor
    • PipelineResult
    • PipelineOptions
      • PipelineOptionsFactory
      • PipelineOptionsRegistrar
    • PipelineRunner
      • PipelineRunnerRegistrar
    • Values
      • PInput
        • PBegin
      • POutput
        • PDone
      • PValue
      • KV
    • DisplayData
      • HasDisplayData
    • Read
    • Source
      • BoundedSource
        • OffsetBasedSource
        • FileBasedSource
        • BlockBasedSource
        • CompressedSource
        • TextSource
      • UnboundedSource
        • CheckpointMark
    • I/O Utilities
      • Create
      • AvroIO
      • KafkaIO
        • Read
        • Write
      • TextIO
    • Metrics
    • Runners
      • Google Cloud Dataflow
        • DataflowRunner
        • DataflowPipelineOptions
        • DataflowPipelineJob
      • Direct Runner
        • DirectRunner
        • DirectPipelineResult
        • PipelineExecutor
        • EvaluationContext
      • Spark Runner
        • SparkStructuredStreamingRunner
        • SparkStructuredStreamingPipelineOptions
    • Coders
      • Coder
      • CoderProvider
      • CoderProviders
      • DefaultCoder
      • CoderRegistry
      • CoderProviderRegistrar
    • Demo
      • Running Pipeline
      • Custom PTransform
    • Misc
      • PipelineDotRenderer
      • Building Beam
Apache Beam 2.21.0
  • Apache Beam
    • 2.21.0
  • Apache Beam
  • Source
  • BoundedSource
  • FileBasedSource
Edit this Page

FileBasedSource

FileBasedSource<T> is an extension of the OffsetBasedSource abstraction for file-based bounded sources that use offsets.

Available FileBasedSources

Table 1. FileBasedSources (Direct Implementations and Extensions Only)
FileBasedSource Description

BlockBasedSource

CompressedSource

TFRecordSource

TextSource

This page was built using the Antora default UI.

The source code for this UI is licensed under the terms of the MPL-2.0 license.