org.apache.spark.sql.avro

Class AvroUtils

Object

org.apache.spark.sql.avro.AvroUtils

public class AvroUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AvroUtils.AvroSchemaHelper Wraps an Avro Schema object so that field lookups are faster.
static interface	AvroUtils.RowReader

Constructor Summary

Constructors

Constructor and Description
AvroUtils()

Method Summary

Modifier and Type	Method and Description
static scala.Option<StructType>	inferSchema(SparkSession spark, scala.collection.immutable.Map<String,String> options, scala.collection.Seq<org.apache.hadoop.fs.FileStatus> files)
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static org.apache.spark.sql.execution.datasources.OutputWriterFactory	prepareWrite(org.apache.spark.sql.internal.SQLConf sqlConf, org.apache.hadoop.mapreduce.Job job, scala.collection.immutable.Map<String,String> options, StructType dataSchema)
static boolean	supportsDataType(DataType dataType)

Methods inherited from class Object

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

Constructor Detail

AvroUtils

public AvroUtils()

Method Detail

inferSchema

public static scala.Option<StructType> inferSchema(SparkSession spark,
                                                   scala.collection.immutable.Map<String,String> options,
                                                   scala.collection.Seq<org.apache.hadoop.fs.FileStatus> files)

supportsDataType

public static boolean supportsDataType(DataType dataType)

prepareWrite

public static org.apache.spark.sql.execution.datasources.OutputWriterFactory prepareWrite(org.apache.spark.sql.internal.SQLConf sqlConf,
                                                                                          org.apache.hadoop.mapreduce.Job job,
                                                                                          scala.collection.immutable.Map<String,String> options,
                                                                                          StructType dataSchema)

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)