Q: How to use PostgreSQL sink from Java akka?

MfgLabs / akka-stream-extensions

Extensions for Akka Stream

Apache License 2.0

123 stars 27 forks source link

Q: How to use PostgreSQL sink from Java akka? #22

Closed nikos closed 7 years ago

nikos commented 8 years ago

Any hint would be fantastic to see how PgStream#insertStreamToTable can be used as sink from a Java perspective? Thanks, Niko

Timshel commented 7 years ago

Almost one year late, but insertStreamToTable is a Flow so you would need to combine it (to) with a sink (Ex: Sink.ignore) to obtain a Sink.