public interface ITransportPlugin
Interface for Thrift Transport plugin.
| Modifier and Type | Method and Description |
|---|---|
default boolean |
areWorkerTokensSupported()
Check if worker tokens are supported by this transport.
|
org.apache.storm.thrift.transport.TTransport |
connect(org.apache.storm.thrift.transport.TTransport transport,
String serverHost,
String asUser)
Connect to the specified server via framed transport.
|
int |
getPort()
Get port.
|
org.apache.storm.thrift.server.TServer |
getServer(org.apache.storm.thrift.TProcessor processor)
Create a server associated with a given port, service handler, and purpose.
|
void |
prepare(ThriftConnectionType type,
Map<String,Object> topoConf)
Invoked once immediately after construction.
|
void prepare(ThriftConnectionType type, Map<String,Object> topoConf)
Invoked once immediately after construction.
type - the type of connection this will process.topoConf - Storm configurationorg.apache.storm.thrift.server.TServer getServer(org.apache.storm.thrift.TProcessor processor)
throws IOException,
org.apache.storm.thrift.transport.TTransportException
Create a server associated with a given port, service handler, and purpose.
processor - service handlerIOExceptionorg.apache.storm.thrift.transport.TTransportExceptionorg.apache.storm.thrift.transport.TTransport connect(org.apache.storm.thrift.transport.TTransport transport,
String serverHost,
String asUser)
throws IOException,
org.apache.storm.thrift.transport.TTransportException
Connect to the specified server via framed transport.
transport - The underlying Thrift transport.serverHost - server hostasUser - the user as which the connection should be established, and all the subsequent actions should be executed. Only applicable when using secure storm cluster. A null/blank value here will just indicate to use the logged in user.IOExceptionorg.apache.storm.thrift.transport.TTransportExceptionint getPort()
Get port.
getServer(org.apache.storm.thrift.TProcessor) has been calleddefault boolean areWorkerTokensSupported()
Check if worker tokens are supported by this transport.
Copyright © 2021 The Apache Software Foundation. All rights reserved.