org.apache.spark.sql.avro

Class AvroUtils.AvroSchemaHelper

Object

org.apache.spark.sql.avro.AvroUtils.AvroSchemaHelper

Enclosing class:

AvroUtils

public static class AvroUtils.AvroSchemaHelper
extends Object

Wraps an Avro Schema object so that field lookups are faster.

param: avroSchema The schema in which to search for fields. Must be of type RECORD.

Constructor Summary

Constructors

Constructor and Description
AvroSchemaHelper(org.apache.avro.Schema avroSchema)

Method Summary

Modifier and Type	Method and Description
scala.Option<org.apache.avro.Schema.Field>	getFieldByName(String name) Extract a single field from the contained avro schema which has the desired field name, performing the matching with proper case sensitivity according to SQLConf.resolver.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroSchemaHelper

public AvroSchemaHelper(org.apache.avro.Schema avroSchema)

Method Detail

getFieldByName

public scala.Option<org.apache.avro.Schema.Field> getFieldByName(String name)

Extract a single field from the contained avro schema which has the desired field name, performing the matching with proper case sensitivity according to SQLConf.resolver.

Parameters:

name - The name of the field to search for.

Returns:

Some(match) if a matching Avro field is found, otherwise None.