public class SimpleTransportPlugin extends Object implements ITransportPlugin
Modifier and Type | Field and Description |
---|---|
protected Configuration |
login_conf |
Constructor and Description |
---|
SimpleTransportPlugin() |
Modifier and Type | Method and Description |
---|---|
org.apache.thrift.transport.TTransport |
connect(org.apache.thrift.transport.TTransport transport,
String serverHost)
Connect to the specified server via framed transport
|
org.apache.thrift.server.TServer |
getServer(int port,
org.apache.thrift.TProcessor processor)
We will let Thrift to apply default transport factory
|
void |
prepare(Map storm_conf,
Configuration login_conf)
Invoked once immediately after construction
|
protected Configuration login_conf
public void prepare(Map storm_conf, Configuration login_conf)
prepare
in interface ITransportPlugin
conf
- Storm configurationlogin_conf
- login configurationpublic org.apache.thrift.server.TServer getServer(int port, org.apache.thrift.TProcessor processor) throws IOException, org.apache.thrift.transport.TTransportException
getServer
in interface ITransportPlugin
port
- listening portprocessor
- service handlerIOException
org.apache.thrift.transport.TTransportException
public org.apache.thrift.transport.TTransport connect(org.apache.thrift.transport.TTransport transport, String serverHost) throws org.apache.thrift.transport.TTransportException
connect
in interface ITransportPlugin
transport
- The underlying Thrift transport.serverHost
- server hostorg.apache.thrift.transport.TTransportException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.