Package | Description |
---|---|
org.apache.storm.multilang | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
void |
JsonSerializer.writeBoltMsg(BoltMsg boltMsg) |
void |
ISerializer.writeBoltMsg(BoltMsg msg)
This method sends a bolt message to a non-JVM bolt process
|
Modifier and Type | Method and Description |
---|---|
void |
ShellBoltMessageQueue.putBoltMsg(BoltMsg boltMsg)
put bolt message to its queue
|
void |
ShellProcess.writeBoltMsg(BoltMsg msg) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.