ThriftSerializerWithClassName

/**                                                                                                                                                                                                         
 * Class that wraps a TSerializer.                                                                                                                                                                          
 */
class ThriftSerializerWithClassName[T <: BoundedTBase] {
  val protocolFactory = new TCompactProtocol.Factory()

  // TSerializer reuses a ByteArrayOutputStream, but isn't threadsafe.                                                                                                                                      
  val serializer = new TSerializer(protocolFactory)

  def serialize(t: T): Array[Byte] = {
    serializer.serialize(t)
  }
}