Skip to content

Instantly share code, notes, and snippets.

View zeitgeist's full-sized avatar

Martin Pompéry zeitgeist

View GitHub Profile

Keybase proof

I hereby claim:

  • I am zeitgeist on github.
  • I am martins (https://keybase.io/martins) on keybase.
  • I have a public key ASBhAsUkyJ-hfar2-nqYv3mm2l39QD4TBMNrr2tP0aDNRgo

To claim this, I am signing this object:

import org.apache.flink.api.common.io.RichInputFormat
import org.apache.flink.api.java.io.jdbc.JDBCInputFormat
import org.apache.flink.api.java.typeutils.ResultTypeQueryable
import org.apache.flink.api.scala._
import org.apache.flink.api.common.typeinfo.BasicTypeInfo
import org.apache.flink.api.table.Row
import org.apache.flink.api.table.typeutils.RowTypeInfo
import org.apache.flink.core.io.InputSplit
/**

Keybase proof

I hereby claim:

  • I am zeitgeist on github.
  • I am martins (https://keybase.io/martins) on keybase.
  • I have a public key ASBG3D9bGYNj_Lmd7esb4QcfRSdMjzaTxXwR4LJNjdV1BQo

To claim this, I am signing this object:

@zeitgeist
zeitgeist / gist:5146904
Created March 12, 2013 20:51
C++ Connection Setup; Finagle-Thrift-Server
struct ThriftTransport {
static const int CONNECT_TIMEOUT = 30000; // 30s
static const int RECV_TIMEOUT = 120000; // 120s
static const int SEND_TIMEOUT = 120000; // 120s
boost::shared_ptr<TSocket> socket;
boost::shared_ptr<TTransport> transport;
boost::shared_ptr<TProtocol> protocol;
ThriftTransport(int port) :