Create a trigger function that can push the spark mutation to Spark Stream (This can go via a distributed MQ like Kafka/ZeroMQ) We should use the C\* trigger functionality for this.