Package org.apache.beam.sdk.io.thrift

package org.apache.beam.sdk.io.thrift

Transforms for reading and writing to Thrift files.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

Classes

Class	Description
ThriftCoder<T>	A Coder using a Thrift TProtocol to serialize/deserialize elements.
ThriftIO	PTransforms for reading and writing files containing Thrift encoded data.
ThriftIO.ReadFiles<T>	Implementation of ThriftIO.readFiles(java.lang.Class<T>).
ThriftIO.Sink<T extends org.apache.thrift.TBase<?,?>>	Implementation of ThriftIO.sink(org.apache.thrift.protocol.TProtocolFactory).
ThriftIO.ThriftWriter<T extends org.apache.thrift.TBase<?,?>>	Writer to write Thrift object to OutputStream.
ThriftPayloadSerializerProvider
ThriftSchema	Schema provider for generated thrift types.
ThriftSchema.Customizer