com.google.cloud.dataflow.sdk.io

Interfaces

• BoundedSource.BoundedReader
• CompressedSource.DecompressingChannelFactory
• Source.Reader
• UnboundedSource.CheckpointMark
• UnboundedSource.UnboundedReader

Classes

• AvroIO
• AvroIO.Read
• AvroIO.Read.Bound
• AvroIO.Write
• AvroIO.Write.Bound
• AvroSource
• AvroSource.AvroReader
• BigQueryIO
• BigQueryIO.Read
• BigQueryIO.Read.Bound
• BigQueryIO.Write
• BigQueryIO.Write.Bound
• BlockBasedSource
• BlockBasedSource.Block
• BlockBasedSource.BlockBasedReader
• BoundedSource
• BoundedSource.AbstractBoundedReader
• ByteOffsetBasedSource
• ByteOffsetBasedSource.ByteOffsetBasedReader
• CompressedSource
• CompressedSource.CompressedReader
• DatastoreIO
• DatastoreIO.DatastoreReader
• DatastoreIO.Sink
• DatastoreIO.Source
• FileBasedSink
• FileBasedSink.FileBasedWriteOperation
• FileBasedSink.FileBasedWriter
• FileBasedSink.FileResult
• FileBasedSource
• FileBasedSource.FileBasedReader
• PubsubIO
• PubsubIO.PubsubSubscription
• PubsubIO.PubsubTopic
• PubsubIO.Read
• PubsubIO.Read.Bound
• PubsubIO.Write
• PubsubIO.Write.Bound
• Read
• Read.Bound
• ShardNameTemplate
• Sink
• Sink.WriteOperation
• Sink.Writer
• Source
• Source.AbstractReader
• TextIO
• TextIO.Read
• TextIO.Read.Bound
• TextIO.Write
• TextIO.Write.Bound
• UnboundedSource
• XmlSink
• XmlSink.Bound
• XmlSink.XmlWriteOperation
• XmlSink.XmlWriter
• XmlSource

Enums

• BigQueryIO.Write.CreateDisposition
• BigQueryIO.Write.WriteDisposition
• CompressedSource.CompressionMode
• FileBasedSink.FileBasedWriteOperation.TemporaryFileRetention
• FileBasedSource.Mode
• TextIO.CompressionType