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:
I hereby claim:
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 | |
/** |
I hereby claim:
To claim this, I am signing this object:
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) : |