pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] erenavsarogullari opened a new pull request #3046: [Pulsar-Flink] Add Batch Json Sink Support
Date Fri, 23 Nov 2018 18:59:10 GMT
erenavsarogullari opened a new pull request #3046: [Pulsar-Flink] Add Batch Json Sink Support
URL: https://github.com/apache/pulsar/pull/3046
 
 
   ### Motivation
   This PR aims to add Flink - Pulsar Batch Json Sink Support. If user works with Flink DataSet
API and would like to write the DataSets to Pulsar in Json format, this sink can help.
   
   Ref: [Flink Batch Sink API](https://ci.apache.org/projects/flink/flink-docs-stable/dev/batch/#data-sinks)
   
   ### Modifications
   Please find the change-set as follows:
   
   **1-** Defines `PulsarJsonOutputFormat` to write Flink Batch `DataSets` into Pulsar by
providing ready `JsonSerializationSchema`.
   **2-** UT Coverages
   **3-** `FlinkPulsarBatchJsonSinkExample` to show how to be used by users.
   **4-** `README.md `documentation
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message