[ https://issues.apache.org/jira/browse/SPARK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14258639#comment-14258639 ]
Hari Shreedharan commented on SPARK-4960: ----------------------------------------- Awesome! One idea I had is to call it on the store(..) calls. This is a bit tricky though, since some receivers call store(T) and some call store(ArrayBuffer[T]) and some call both (like the Kafka one and soon the Flume one too). > Interceptor pattern in receivers > -------------------------------- > > Key: SPARK-4960 > URL: https://issues.apache.org/jira/browse/SPARK-4960 > Project: Spark > Issue Type: New Feature > Components: Streaming > Reporter: Tathagata Das > > Sometimes it is good to intercept a message received through a receiver and > modify / do something with the message before it is stored into Spark. This > is often referred to as the interceptor pattern. There should be general way > to specify an interceptor function that gets applied to all receivers. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org