gviedma opened a new pull request, #14851: URL: https://github.com/apache/pinot/pull/14851
This PR adds a proof-of-concept for a push-based ingestion API by: * Creating an in-memory ring buffer to store ingested records * Creating a new consumer type that reads from in-memory buffer * Starting a new HTTP server endpoint embedded in the pinot-server to push records to in-memory buffer. To push records to the new end-point, you can use curl like so: ``` curl --header 'Content-Type: application/octet-stream' --data @/Users/genunez/dev/oss/pinot/pinot-tools/src/main/resources/examples/stream/pushBasedIngestionDemo/rawdata/pushBasedIngestionDemo_data.json http://localhost:8989/ingestion/records/${tableName} ``` where _tableName_ is that table you are pushing records to. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
