@Experimental(value=SOURCE_SINK)
See: Description
| 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 |