morpheus.stages.output#

All stages that take inputs but have no outputs.

Modules

compare_dataframe_stage

Output stage that collects received messages and compares the concatinated dataframe of all messages against a known expected dataframe.

http_client_sink_stage

Write all messages to an HTTP endpoint.

http_server_sink_stage

Sink stage that starts an HTTP server and listens for incoming requests on a specified endpoint.

in_memory_sink_stage

write_to_databricks_deltalake_stage

write_to_elasticsearch_stage

Write to Elasticsearch stage.

write_to_file_stage

Write to file stage.

write_to_kafka_stage