Skip to content

Commit a930a7f

Browse files
committed
Prepare for release
1 parent 823c4db commit a930a7f

File tree

4 files changed

+15
-6
lines changed

4 files changed

+15
-6
lines changed

CHANGELOG

+9
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,12 @@
1+
Version 0.3.0 (2019-05-13)
2+
--------------------------
3+
Limit fields and contexts (#23)
4+
Use sbt-tpolecat (#21)
5+
Move to scalaj (#20)
6+
Limit payload size (#22)
7+
Add time measurements (#25)
8+
Extend copyright to 2019 (#26)
9+
110
Version 0.2.0 (2018-11-12)
211
--------------------------
312
Send multiple requests in case of batch size exceeding 100 (#16)

README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ Unless required by applicable law or agreed to in writing, software distributed
2020
[travis-image]: https://travis-ci.org/snowplow-incubator/snowplow-indicative-relay.svg?branch=master
2121
[travis]: https://travis-ci.org/snowplow-incubator/snowplow-indicative-relay
2222

23-
[release-image]: https://img.shields.io/badge/release-0.2.0-orange.svg?style=flat
23+
[release-image]: https://img.shields.io/badge/release-0.3.0-orange.svg?style=flat
2424
[release]: https://github.com/snowplow-incubator/snowplow-indicative-relay/releases
2525

2626
[license-image]: http://img.shields.io/badge/license-Apache--2-blue.svg?style=flat

build.sbt

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ lazy val root = project
1515
.settings(
1616
name := "indicative-relay",
1717
organization := "com.snowplowanalytics",
18-
version := "0.2.0",
18+
version := "0.3.0",
1919
description := "A relay transforming Snowplow enriched events into Indicative format",
2020
scalaVersion := "2.11.12",
2121
javacOptions := BuildSettings.javaCompilerOptions

src/main/scala/com/snowplowanalytics/indicative/LambdaHandler.scala

+4-4
Original file line numberDiff line numberDiff line change
@@ -80,8 +80,7 @@ class LambdaHandler {
8080
()
8181
}
8282

83-
def transform(
84-
record: KinesisEvent.KinesisEventRecord): Option[Either[TransformationError, Json]] = {
83+
def transform(record: KinesisEvent.KinesisEventRecord): Option[Either[TransformationError, Json]] = {
8584
val kinesisDataArray: Either[TransformationError, String] = Option(record.getKinesis)
8685
.flatMap(underlying => Option(underlying.getData))
8786
.filter(_.hasArray)
@@ -94,8 +93,9 @@ class LambdaHandler {
9493
EventTransformer
9594
.transformWithInventory(dataArray)
9695
.leftMap(errors => TransformationError(errors.mkString("\n * "))))
97-
indicativeEvent <- EitherT(Transformer
98-
.transform(snowplowEvent.event, snowplowEvent.inventory, unusedEvents, unusedAtomicFields, unusedContexts))
96+
indicativeEvent <- EitherT(
97+
Transformer
98+
.transform(snowplowEvent.event, snowplowEvent.inventory, unusedEvents, unusedAtomicFields, unusedContexts))
9999
} yield indicativeEvent).value
100100
}
101101

0 commit comments

Comments
 (0)