| Package | Description |
|---|---|
| org.apache.storm.daemon.worker | |
| org.apache.storm.messaging | |
| org.apache.storm.messaging.local | |
| org.apache.storm.messaging.netty | |
| org.apache.storm.utils |
| Modifier and Type | Method and Description |
|---|---|
IConnection |
WorkerState.getReceiver() |
| Modifier and Type | Method and Description |
|---|---|
AtomicReference<Map<NodeInfo,IConnection>> |
WorkerState.getCachedNodeToPortSocket() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
WorkerState.isConnectionReady(IConnection connection) |
| Modifier and Type | Class and Description |
|---|---|
class |
ConnectionWithStatus |
| Modifier and Type | Method and Description |
|---|---|
IConnection |
IContext.bind(String stormId,
int port,
IConnectionCallback cb,
Supplier<Object> newConnectionResponse)
This method establishes a server side connection.
|
IConnection |
IContext.connect(String stormId,
String host,
int port,
AtomicBoolean[] remoteBpStatus)
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 stormId,
int port,
IConnectionCallback cb,
Supplier<Object> newConnectionResponse) |
IConnection |
Context.connect(String stormId,
String host,
int port,
AtomicBoolean[] remoteBpStatus) |
| 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 stormId,
int port,
IConnectionCallback cb,
Supplier<Object> newConnectionResponse)
establish a server with a binding port.
|
IConnection |
Context.connect(String stormId,
String host,
int port,
AtomicBoolean[] remoteBpStatus)
establish a connection to a remote server.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TransferDrainer.send(Map<Integer,NodeInfo> taskToNode,
Map<NodeInfo,IConnection> connections) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.