@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)
ITransportPlugin
Invoked once immediately after construction
prepare
in interface ITransportPlugin
type
- 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
ITransportPlugin
Create a server associated with a given port, service handler, and purpose
getServer
in interface ITransportPlugin
processor
- service handlerIOException
org.apache.thrift.transport.TTransportException
public 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 ITransportPlugin
transport
- The underlying Thrift transport.serverHost
- unused.asUser
- unused.org.apache.thrift.transport.TTransportException
protected Subject getDefaultSubject()
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.