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

Abris #159 add developer api annotations #251

Merged
merged 1 commit into from
Nov 19, 2021
Merged
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
Original file line number Diff line number Diff line change
Expand Up @@ -19,13 +19,15 @@ package org.apache.spark.sql.avro

import org.apache.avro.Schema
import org.apache.spark.sql.types.DataType
import za.co.absa.commons.annotation.DeveloperApi

import scala.util.Try

/**
* Compatibility layer handling different versions of AvroDeserializer
* the package also allows to access package private class
*/
@DeveloperApi
class AbrisAvroDeserializer(rootAvroType: Schema, rootCatalystType: DataType) {

private val deserializer = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,12 @@ package org.apache.spark.sql.avro

import org.apache.avro.Schema
import org.apache.spark.sql.types.DataType
import za.co.absa.commons.annotation.DeveloperApi

/**
* Simple wrapper to access spark package private class
*/
@DeveloperApi
class AbrisAvroSerializer(rootCatalystType: DataType, rootAvroType: Schema, nullable: Boolean) {

private val serializer: AvroSerializer = new AvroSerializer(rootCatalystType, rootAvroType, nullable)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -128,8 +128,3 @@ class SchemaManager(schemaRegistryClient: AbrisRegistryClient) extends Logging {
maybeSchemaId.getOrElse(register(subject, schema))
}
}

@deprecated("This Exception is not used and might be removed in next major release.")
class SchemaManagerException(msg: String, throwable: Throwable) extends RuntimeException(msg, throwable) {
def this(msg: String) = this(msg, null)
}