reservoir-akka

License	The Apache License, Version 2.0
Categories	Akka Container Microservices Reactive libraries
GroupId	lgbt.princess
ArtifactId	reservoir-akka_2.13
Last Version	0.3.0
Release Date	Feb 7, 2021
Type	jar
Description	reservoir-akka reservoir-akka
Project URL	https://github.com/NthPortal/reservoir
Project Organization	lgbt.princess
Source Code Management	https://github.com/NthPortal/reservoir

Download reservoir-akka_2.13

Filename	Size
reservoir-akka_2.13-0.3.0.pom
reservoir-akka_2.13-0.3.0.jar	8 KB
reservoir-akka_2.13-0.3.0-sources.jar	2 KB
reservoir-akka_2.13-0.3.0-javadoc.jar	1 MB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/lgbt.princess/reservoir-akka_2.13/ -->
<dependency>
    <groupId>lgbt.princess</groupId>
    <artifactId>reservoir-akka_2.13</artifactId>
    <version>0.3.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/lgbt.princess/reservoir-akka_2.13/
implementation 'lgbt.princess:reservoir-akka_2.13:0.3.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/lgbt.princess/reservoir-akka_2.13/
implementation ("lgbt.princess:reservoir-akka_2.13:0.3.0")

Apache Buildr

'lgbt.princess:reservoir-akka_2.13:jar:0.3.0'

Apache Ivy

<dependency org="lgbt.princess" name="reservoir-akka_2.13" rev="0.3.0">
  <artifact name="reservoir-akka_2.13" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='lgbt.princess', module='reservoir-akka_2.13', version='0.3.0')
)

Scala SBT

libraryDependencies += "lgbt.princess" % "reservoir-akka_2.13" % "0.3.0"

Leiningen

[lgbt.princess/reservoir-akka_2.13 "0.3.0"]

Dependencies

compile (3)

Group / Artifact	Type	Version
org.scala-lang : scala-library	jar	2.13.4
lgbt.princess : reservoir-core_2.13	jar	0.3.0
com.typesafe.akka : akka-stream_2.13	jar	2.6.12

test (1)

Group / Artifact	Type	Version
org.scalatest : scalatest_2.13	jar	3.2.3

Project Modules

There are no modules declared in this project.

reservoir

Reservoir sampling implementation with Akka Streams support

Add to Your sbt Build

Scala 2.13

libraryDependencies += "lgbt.princess" %% "reservoir-core"        % "0.4.0"  // the core library supporting synchronous reservoir sampling
libraryDependencies += "lgbt.princess" %% "reservoir-akka-stream" % "0.4.0"  // the library for akka-stream operators
libraryDependencies += "lgbt.princess" %% "reservoir"             % "0.4.0"  // all parts of the library

Usage

Reservoir Sampler

import lgbt.princess.reservoir.Sampler

final case class User(id: String, displayName: String)

val sampler = Sampler[User, String](maxSampleSize = 100)(_.id)
sampler.sampleAll(onlineUsers())
val sampleIds = sampler.result()

val distinctSampler = Sampler.distinct[User, String](maxSampleSize = 100)(_.id)
distinctSampler.sampleAll(onlineUsers())
val distinctSampleIds = distinctSampler.result()

Akka Stream Operator

import akka.stream.scaladsl.{Keep, Sink}
import lgbt.princess.reservoir.akkasupport.Sample

final case class User(id: String, displayName: String)

val (users1, sampleIds) = onlineUsers()
  .viaMat(Sample[User, String](maxSampleSize = 100)(_.id))(Keep.right)
  .toMat(Sink.seq)(Keep.both)
  .run()
  
val (users2, distinctSampleIds) = onlineUsers()
  .viaMat(Sample.distinct[User, String](maxSampleSize = 100)(_.id))(Keep.right)
  .toMat(Sink.seq)(Keep.both)
  .run()

Versions

Version
0.3.0 Feb 7, 2021
0.2.1 Apr 9, 2020
0.2.0 Apr 5, 2020
0.1.1 Mar 28, 2020
0.1.0 Mar 28, 2020