public interface ITransportPlugin
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)
Create a server associated with a given port and service handler
|
void |
prepare(Map storm_conf,
Configuration login_conf)
Invoked once immediately after construction
|
void prepare(Map storm_conf, Configuration login_conf)
storm_conf
- Storm configurationlogin_conf
- login configurationorg.apache.thrift.server.TServer getServer(int port, org.apache.thrift.TProcessor processor) throws IOException, org.apache.thrift.transport.TTransportException
port
- listening portprocessor
- service handlerIOException
org.apache.thrift.transport.TTransportException
org.apache.thrift.transport.TTransport connect(org.apache.thrift.transport.TTransport transport, String serverHost) throws IOException, org.apache.thrift.transport.TTransportException
transport
- The underlying Thrift transport.serverHost
- server hostIOException
org.apache.thrift.transport.TTransportException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.