public class AvroUtils
extends Object
Modifier and Type | Class and Description |
---|---|
static class |
AvroUtils.AvroMatchedField$ |
static class |
AvroUtils.AvroSchemaHelper
Helper class to perform field lookup/matching on Avro schemas.
|
static interface |
AvroUtils.RowReader |
Constructor and Description |
---|
AvroUtils() |
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) |
public static scala.Option<StructType> inferSchema(SparkSession spark, scala.collection.immutable.Map<String,String> options, scala.collection.Seq<org.apache.hadoop.fs.FileStatus> files)
public static boolean supportsDataType(DataType dataType)
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)
public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)