Skip to content

Commit

Permalink
Update SortMergeBucketExample.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
clairemcginty authored Jan 25, 2024
1 parent e81fc26 commit 78a010e
Showing 1 changed file with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -211,8 +211,6 @@ object SortMergeBucketTransformExample {
case class CombinedAccount(id: Int, age: Int, totalValue: Double)

def pipeline(sc: ScioContext, args: Args): ClosedTap[CombinedAccount] = {
implicit val coder: Coder[GenericRecord] = avroGenericRecordCoder(

implicit val coderUserData: Coder[GenericRecord] =
avroGenericRecordCoder(SortMergeBucketExample.UserDataSchema)
implicit val coderAccount: Coder[Account] =
Expand Down

0 comments on commit 78a010e

Please sign in to comment.