Package org.apache.storm.multilang
Class JsonSerializer
java.lang.Object
org.apache.storm.multilang.JsonSerializer
- All Implemented Interfaces:
Serializable,ISerializer
JsonSerializer implements the JSON multilang protocol.
- See Also:
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionconnect(Map<String, Object> conf, TopologyContext context) This method transmits the Storm config to the non-JVM process and receives its pid.voidinitialize(OutputStream processIn, InputStream processOut) This method sets the input and output streams of the serializer.This method receives a shell message from the non-JVM process.voidwriteBoltMsg(BoltMsg boltMsg) This method sends a bolt message to a non-JVM bolt process.voidwriteSpoutMsg(SpoutMsg msg) This method sends a spout message to a non-JVM spout process.voidwriteTaskIds(List<Integer> taskIds) This method sends a list of task IDs to a non-JVM bolt process.
-
Field Details
-
DEFAULT_CHARSET
- See Also:
-
-
Constructor Details
-
JsonSerializer
public JsonSerializer()
-
-
Method Details
-
initialize
Description copied from interface:ISerializerThis method sets the input and output streams of the serializer.- Specified by:
initializein interfaceISerializer- Parameters:
processIn- output stream to non-JVM componentprocessOut- input stream from non-JVM component
-
connect
public Number connect(Map<String, Object> conf, TopologyContext context) throws IOException, NoOutputExceptionDescription copied from interface:ISerializerThis method transmits the Storm config to the non-JVM process and receives its pid.- Specified by:
connectin interfaceISerializer- Parameters:
conf- storm configurationcontext- topology context- Returns:
- process pid
- Throws:
IOExceptionNoOutputException
-
writeBoltMsg
Description copied from interface:ISerializerThis method sends a bolt message to a non-JVM bolt process.- Specified by:
writeBoltMsgin interfaceISerializer- Parameters:
boltMsg- bolt message- Throws:
IOException
-
writeSpoutMsg
Description copied from interface:ISerializerThis method sends a spout message to a non-JVM spout process.- Specified by:
writeSpoutMsgin interfaceISerializer- Parameters:
msg- spout message- Throws:
IOException
-
writeTaskIds
Description copied from interface:ISerializerThis method sends a list of task IDs to a non-JVM bolt process.- Specified by:
writeTaskIdsin interfaceISerializer- Parameters:
taskIds- list of task IDs- Throws:
IOException
-
readShellMsg
Description copied from interface:ISerializerThis method receives a shell message from the non-JVM process.- Specified by:
readShellMsgin interfaceISerializer- Returns:
- shell message
- Throws:
IOExceptionNoOutputException
-