org.apache.beam.sdk.io

Interfaces

• AvroIO.RecordFormatter
• AvroSink.DatumWriterFactory
• AvroSource.DatumReaderFactory
• CompressedSource.DecompressingChannelFactory
• FileBasedSink.OutputFileHints
• FileBasedSink.WritableByteChannelFactory
• FileIO.Sink
• FileIO.Write.FileNaming
• FileSystemRegistrar
• ShardingFunction
• TextRowCountEstimator.SamplingStrategy
• UnboundedSource.CheckpointMark

Classes

• AvroIO
• AvroIO.Parse
• AvroIO.ParseAll
• AvroIO.ParseFiles
• AvroIO.Read
• AvroIO.ReadAll
• AvroIO.ReadFiles
• AvroIO.Sink
• AvroIO.TypedWrite
• AvroIO.Write
• AvroSchemaIOProvider
• AvroSink
• AvroSource
• AvroSource.AvroReader
• BlockBasedSource
• BlockBasedSource.Block
• BlockBasedSource.BlockBasedReader
• BoundedReadFromUnboundedSource
• BoundedSource
• BoundedSource.BoundedReader
• ClassLoaderFileSystem
• ClassLoaderFileSystem.ClassLoaderFileSystemRegistrar
• ClassLoaderFileSystem.ClassLoaderResourceId
• CompressedSource
• CompressedSource.CompressedReader
• CountingSource
• CountingSource.CounterMark
• DefaultFilenamePolicy
• DefaultFilenamePolicy.Params
• DefaultFilenamePolicy.ParamsCoder
• DynamicAvroDestinations
• DynamicFileDestinations
• FileBasedSink
• FileBasedSink.DynamicDestinations
• FileBasedSink.FilenamePolicy
• FileBasedSink.FileResult
• FileBasedSink.FileResultCoder
• FileBasedSink.WriteOperation
• FileBasedSink.Writer
• FileBasedSource
• FileBasedSource.FileBasedReader
• FileIO
• FileIO.Match
• FileIO.MatchAll
• FileIO.MatchConfiguration
• FileIO.ReadableFile
• FileIO.ReadMatches
• FileIO.Write
• FileSystem
• FileSystems
• FileSystemUtils
• GenerateSequence
• GenerateSequence.External
• GenerateSequence.External.ExternalConfiguration
• LocalFileSystemRegistrar
• LocalResources
• OffsetBasedSource
• OffsetBasedSource.OffsetBasedReader
• Read
• Read.Bounded
• Read.Builder
• Read.Unbounded
• ReadableFileCoder
• ReadAllViaFileBasedSource
• ReadAllViaFileBasedSource.ReadFileRangesFnExceptionHandler
• ShardNameTemplate
• Source
• Source.Reader
• TextIO
• TextIO.Read
• TextIO.ReadAll
• TextIO.ReadFiles
• TextIO.Sink
• TextIO.TypedWrite
• TextIO.Write
• TextRowCountEstimator
• TextRowCountEstimator.Builder
• TextRowCountEstimator.LimitNumberOfFiles
• TextRowCountEstimator.LimitNumberOfTotalBytes
• TextRowCountEstimator.SampleAllFiles
• TFRecordIO
• TFRecordIO.Read
• TFRecordIO.ReadFiles
• TFRecordIO.Sink
• TFRecordIO.Write
• UnboundedSource
• UnboundedSource.CheckpointMark.NoopCheckpointMark
• UnboundedSource.UnboundedReader
• WriteFiles
• WriteFilesResult

Enums

• CompressedSource.CompressionMode
• Compression
• FileBasedSink.CompressionType
• FileBasedSource.Mode
• FileIO.ReadMatches.DirectoryTreatment
• TextIO.CompressionType
• TFRecordIO.CompressionType

Exceptions

• TextRowCountEstimator.NoEstimationException