Package | Description |
---|---|
org.apache.storm.messaging | |
org.apache.storm.messaging.local | |
org.apache.storm.messaging.netty | |
org.apache.storm.utils |
Modifier and Type | Class and Description |
---|---|
class |
ConnectionWithStatus |
Modifier and Type | Method and Description |
---|---|
IConnection |
IContext.bind(String storm_id,
int port)
This method establishes a server side connection
|
IConnection |
IContext.connect(String storm_id,
String host,
int port)
This method establish a client side connection to a remote server implementation should return a new connection every call
|
Modifier and Type | Method and Description |
---|---|
IConnection |
Context.bind(String storm_id,
int port) |
IConnection |
Context.connect(String storm_id,
String host,
int port) |
Modifier and Type | Class and Description |
---|---|
class |
Client
A Netty client for sending task messages to a remote destination (Netty server).
|
Modifier and Type | Method and Description |
---|---|
IConnection |
Context.bind(String storm_id,
int port)
establish a server with a binding port
|
IConnection |
Context.connect(String storm_id,
String host,
int port)
establish a connection to a remote server
|
Modifier and Type | Method and Description |
---|---|
void |
TransferDrainer.send(HashMap<Integer,String> taskToNode,
HashMap<String,IConnection> connections) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.