Dala.Spark.Transformers.Pubsub (dala v0.0.12)

Copy Markdown View Source

Spark transformer that handles PubSub subscriptions from DSL.

Generates handle_info/2 clauses for each subscription declared in the pubsub section, forwarding messages to the specified handler. Also manages subscribe/unsubscribe in mount/terminate.

Summary

Functions

after?(_)

Callback implementation for Spark.Dsl.Transformer.after?/1.

after_compile?()

Callback implementation for Spark.Dsl.Transformer.after_compile?/0.

before?(_)

Callback implementation for Spark.Dsl.Transformer.before?/1.

Functions

after?(_)

Callback implementation for Spark.Dsl.Transformer.after?/1.

after_compile?()

Callback implementation for Spark.Dsl.Transformer.after_compile?/0.

before?(_)

Callback implementation for Spark.Dsl.Transformer.before?/1.