Skip to content

Commit 12bab2c

Browse files
committed
Add slash at the end of the load path
1 parent 0b447df commit 12bab2c

File tree

2 files changed

+4
-4
lines changed
  • modules
    • loader/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/discovery
    • redshift-loader/src/test/scala/com/snowplowanalytics/snowplow/loader/redshift

2 files changed

+4
-4
lines changed

Diff for: modules/loader/src/main/scala/com/snowplowanalytics/snowplow/rdbloader/discovery/ShreddedType.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ object ShreddedType {
6464
*/
6565
final case class Json(info: Info, jsonPaths: BlobStorage.Key) extends ShreddedType {
6666
def getLoadPath: String =
67-
s"${info.base}${Common.GoodPrefix}/vendor=${info.vendor}/name=${info.name}/format=json/model=${info.version.model}/revision=${info.version.revision}/addition=${info.version.addition}"
67+
s"${info.base}${Common.GoodPrefix}/vendor=${info.vendor}/name=${info.name}/format=json/model=${info.version.model}/revision=${info.version.revision}/addition=${info.version.addition}/"
6868

6969
def show: String = s"${info.toCriterion.asString} ($jsonPaths)"
7070
}
@@ -78,7 +78,7 @@ object ShreddedType {
7878
*/
7979
final case class Tabular(info: Info) extends ShreddedType {
8080
def getLoadPath: String =
81-
s"${info.base}${Common.GoodPrefix}/vendor=${info.vendor}/name=${info.name}/format=tsv/model=${info.version.model}/revision=${info.version.revision}/addition=${info.version.addition}"
81+
s"${info.base}${Common.GoodPrefix}/vendor=${info.vendor}/name=${info.name}/format=tsv/model=${info.version.model}/revision=${info.version.revision}/addition=${info.version.addition}/"
8282

8383
def show: String = s"${info.toCriterion.asString} TSV"
8484
}

Diff for: modules/redshift-loader/src/test/scala/com/snowplowanalytics/snowplow/loader/redshift/RedshiftSpec.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -144,8 +144,8 @@ class RedshiftSpec extends Specification {
144144
result.toList must containTheSameElementsAs(
145145
List(
146146
"COPY events FROM s3://my-bucket/my-path/", // atomic
147-
"COPY com_acme_event_2 FROM s3://my-bucket/my-path/output=good/vendor=com.acme/name=event/format=tsv/model=2/revision=0/addition=0",
148-
"COPY com_acme_event_3 FROM s3://my-bucket/my-path/output=good/vendor=com.acme/name=event/format=tsv/model=3/revision=0/addition=0"
147+
"COPY com_acme_event_2 FROM s3://my-bucket/my-path/output=good/vendor=com.acme/name=event/format=tsv/model=2/revision=0/addition=0/",
148+
"COPY com_acme_event_3 FROM s3://my-bucket/my-path/output=good/vendor=com.acme/name=event/format=tsv/model=3/revision=0/addition=0/"
149149
)
150150
)
151151
}

0 commit comments

Comments
 (0)