jcdavis

production@ class A {
            case class B(a: Int)
            } 
defined class A
production@ kryo.writeObject(output, (new A).B(42)) 
38:44 DEBUG: [kryo] Write: B(42)
38:44 TRACE: [kryo] Optimize ints: true
38:44 TRACE: [kryo] Field a: int
38:44 TRACE: [kryo.FieldSerializerConfig] setIgnoreSyntheticFields: false
38:44 TRACE: [kryo] Field a: int

jcdavis

import com.twitter.scalding.Job
import com.twitter.scalding.typed.{CoGroupable, Grouped, TypedPipe, UnsortedGrouped}

import scala.reflect.runtime.universe

object ThriftClassFinder {
  private val structures: Set[Class[_]] = Set(
    classOf[TypedPipe[_]],
    classOf[Grouped[_,_]],
    classOf[UnsortedGrouped[_,_]],

jcdavis

#include <stdlib.h>
#include <stdio.h>
#include <string.h>

int main(int argc, char** argv) {
  char buffer[4096];
  FILE* inf = fopen(argv[1], "r");
  FILE* outf = fopen(argv[2], "w");

  while(fgets(buffer ,4096, inf)) {