Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions .git-blame-ignore-revs
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
# Scala Steward: Reformat with scalafmt 3.8.6
ea8e30732bee9b9cd1244337420be56fad291542
2 changes: 1 addition & 1 deletion .scalafmt.conf
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
version=3.8.0
version=3.8.6
runner.dialect = scala212
fileOverride {
"glob:**/scala-2.13*/**" {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -348,7 +348,6 @@ object ExpHist {
*
* - Find the largest j s.t. 2^j <= (s + l) / (1 + l)
* - let s' = 2^j(1 + l) - l
*
* - let diff = (s - s') is the position of s within that group.
* - let b = the little-endian binary rep of diff % (2^j - 1)
* - let ret = return vector of length j:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -282,24 +282,28 @@ class TupleAggregatorsTest extends AnyWordSpec with Matchers {
}

"Create an aggregator from a tuple of 16 aggregators" in {
val agg: Aggregator[Int, Tuple16[
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
val agg: Aggregator[
Int,
Int
], Tuple16[Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int]] = Tuple16(
Tuple16[
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int
],
Tuple16[Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int]
] = Tuple16(
MinAgg,
MinAgg,
MinAgg,
Expand Down Expand Up @@ -975,24 +979,28 @@ class TupleAggregatorsTest extends AnyWordSpec with Matchers {
}

"Create an aggregator from a tuple of 16 aggregators" in {
val agg: Aggregator[Int, Tuple16[
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
val agg: Aggregator[
Int,
Int
], Tuple16[Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int]] =
Tuple16[
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int,
Int
],
Tuple16[Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int, Int]
] =
MultiAggregator(
(
MinAgg,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,8 @@ import com.twitter.util.Promise
* general version of the TunnelMonoid. See the documentation for TunnelMonoid for general motivation. NOTE:
* the Promise will be fulfilled with the value just before the PromiseLink is calculated.
*/
class PromiseLinkMonoid[V](monoid: Monoid[V]) extends Monoid[PromiseLink[V]] { // TODo(jcoveney) rename PromiseLink
class PromiseLinkMonoid[V](monoid: Monoid[V])
extends Monoid[PromiseLink[V]] { // TODo(jcoveney) rename PromiseLink
def zero: PromiseLink[V] = PromiseLink(new Promise, monoid.zero)

def plus(older: PromiseLink[V], newer: PromiseLink[V]): PromiseLink[V] = {
Expand Down
Loading