Package org.apache.storm.messaging
Class DeserializingConnectionCallback
java.lang.Object
org.apache.storm.messaging.DeserializingConnectionCallback
- All Implemented Interfaces:
- IConnectionCallback,- IMetric
A class that is called when a TaskMessage arrives.
- 
Constructor SummaryConstructorsConstructorDescriptionDeserializingConnectionCallback(Map<String, Object> conf, GeneralTopologyContext context, WorkerState.ILocalTransferCallback callback) 
- 
Method SummaryModifier and TypeMethodDescriptionReturns serialized byte count traffic metrics.voidrecv(List<TaskMessage> batch) A batch of new messages have arrived to be processed.protected voidupdateMetrics(int sourceTaskId, TaskMessage message) Update serialized byte counts for each message.Methods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.metric.api.IMetricgetDimensions
- 
Constructor Details- 
DeserializingConnectionCallbackpublic DeserializingConnectionCallback(Map<String, Object> conf, GeneralTopologyContext context, WorkerState.ILocalTransferCallback callback) 
 
- 
- 
Method Details- 
recvDescription copied from interface:IConnectionCallbackA batch of new messages have arrived to be processed.- Specified by:
- recvin interface- IConnectionCallback
- Parameters:
- batch- the messages to be processed
 
- 
getValueAndResetReturns serialized byte count traffic metrics.- Specified by:
- getValueAndResetin interface- IMetric
- Returns:
- Map of metric counts, or null if disabled
 
- 
updateMetricsUpdate serialized byte counts for each message.- Parameters:
- sourceTaskId- source task
- message- serialized message
 
 
-