@Experimental(value=SOURCE_SINK)

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

Transforms for reading and writing to Thrift files.

See: Description

Class Summary

Class	Description
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.

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

Transforms for reading and writing to Thrift files.