@Deprecated public class SimpleTransportPlugin extends Object implements ITransportPlugin
Simple transport for Thrift plugin.
This plugin is designed to be backward compatible with existing Storm code.
| Modifier and Type | Field and Description |
|---|---|
protected Configuration |
login_conf
Deprecated.
|
protected Map |
storm_conf
Deprecated.
|
protected ThriftConnectionType |
type
Deprecated.
|
| Constructor and Description |
|---|
SimpleTransportPlugin()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
org.apache.thrift.transport.TTransport |
connect(org.apache.thrift.transport.TTransport transport,
String serverHost,
String asUser)
Deprecated.
Connect to the specified server via framed transport
|
protected Subject |
getDefaultSubject()
Deprecated.
|
org.apache.thrift.server.TServer |
getServer(org.apache.thrift.TProcessor processor)
Deprecated.
Create a server associated with a given port, service handler, and purpose
|
void |
prepare(ThriftConnectionType type,
Map storm_conf,
Configuration login_conf)
Deprecated.
Invoked once immediately after construction
|
protected ThriftConnectionType type
protected Map storm_conf
protected Configuration login_conf
public void prepare(ThriftConnectionType type, Map storm_conf, Configuration login_conf)
ITransportPluginInvoked once immediately after construction
prepare in interface ITransportPlugintype - the type of connection this will process.storm_conf - Storm configurationlogin_conf - login configurationpublic org.apache.thrift.server.TServer getServer(org.apache.thrift.TProcessor processor)
throws IOException,
org.apache.thrift.transport.TTransportException
ITransportPluginCreate a server associated with a given port, service handler, and purpose
getServer in interface ITransportPluginprocessor - service handlerIOExceptionorg.apache.thrift.transport.TTransportExceptionpublic org.apache.thrift.transport.TTransport connect(org.apache.thrift.transport.TTransport transport,
String serverHost,
String asUser)
throws org.apache.thrift.transport.TTransportException
Connect to the specified server via framed transport
connect in interface ITransportPlugintransport - The underlying Thrift transport.serverHost - unused.asUser - unused.org.apache.thrift.transport.TTransportExceptionprotected Subject getDefaultSubject()
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.