Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

support scala3 in avroparquet #158

Merged
merged 7 commits into from
Jun 12, 2023
Merged

support scala3 in avroparquet #158

merged 7 commits into from
Jun 12, 2023

Conversation

pjfanning
Copy link
Contributor

@pjfanning pjfanning commented Jun 9, 2023

part of #126

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala
@pjfanning pjfanning marked this pull request as draft June 11, 2023 07:56
@pjfanning pjfanning marked this pull request as ready for review June 11, 2023 08:28
@pjfanning
Copy link
Contributor Author

@mdedetrich @He-Pin @nvollmar would any of you time to review this? It is the final easy Scala3 transition. The other harder ones have issues raised for them - https://github.com/apache/incubator-pekko-connectors/issues?q=is%3Aissue+is%3Aopen+label%3Ascala3

@@ -167,13 +167,16 @@ object Dependencies {
"com.google.jimfs" % "jimfs" % "1.2" % Test // ApacheV2
))

val avro4sVersion: Def.Initialize[String] = Def.setting {
if (scalaVersion.value.startsWith("2")) "4.1.1" else "5.0.4"
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I see.

val folder: String = "./" + Random.alphanumeric.take(8).mkString("")

val genFinalFile: Gen[String] = for {
fileName <- Gen.alphaLowerStr
} yield { folder + "/" + fileName + ".parquet" }
} yield {
folder + "/" + fileName + ".parquet"
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

use File.seperator?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this code was just moved around - I did not rewrite it - I just need to have the code set up so some code can be different in Scala 2 and Scala 3

it would be bad imo for me to start rewriting working code in a PR that is about purely Scala3 support

if we want to rewrite working code that we don't like, we really need new PRs

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'm not sure how the code got reformatted. Possibly my IDE - possibly scalafmt. If this is an issue I can try to change the formatting of this line back.

Copy link
Contributor

@mdedetrich mdedetrich left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

Copy link
Member

@He-Pin He-Pin left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

@He-Pin He-Pin merged commit 6c8bf6c into apache:scala3 Jun 12, 2023
@pjfanning pjfanning deleted the scala3-avro branch June 12, 2023 13:04
pjfanning added a commit that referenced this pull request Jun 26, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Jun 26, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Jun 27, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Jul 14, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Aug 3, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Aug 6, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Aug 6, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Aug 11, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
mdedetrich pushed a commit to mdedetrich/pekko-connectors that referenced this pull request Aug 15, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Aug 17, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
pjfanning added a commit that referenced this pull request Aug 19, 2023
* support scala3 in avroparquet

add some scala3 tests

Update AvroParquetSinkSpec.scala

Update avroparquet.md

Update AbstractAvroParquet.scala

Update AbstractAvroParquet.scala

* refactor test code

* Update AbstractAvroParquetBase.scala

* fix doc links

* use Common.isScala3

* Update Dependencies.scala

* Update build.sbt
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants