Class AvroUtils

Object
org.apache.spark.sql.avro.AvroUtils

public class AvroUtils extends Object
  • Constructor Details

    • AvroUtils

      public AvroUtils()
  • Method Details

    • inferSchema

      public static scala.Option<StructType> inferSchema(SparkSession spark, scala.collection.immutable.Map<String,String> options, scala.collection.immutable.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)
    • LogStringContext

      public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)