Class AvroFileFormat<T>

Type Parameters:
T - type of items a source using this file format will emit
All Implemented Interfaces:
FileFormat<T>, Serializable

public class AvroFileFormat<T>
extends Object
implements FileFormat<T>
FileFormat for avro files. See FileFormat.avro() for more details.
See Also:
Serialized Form
  • Field Details

  • Method Details

    • withReflect

      @Nonnull public AvroFileFormat<T> withReflect​(@Nullable Class<T> reflectClass)
      Specifies to use reflection to deserialize data into the given class. Jet will use the ReflectDatumReader to read Avro data. The parameter may be null, this disables the option to deserialize using reflection.
      reflectClass - class to deserialize data into
    • reflectClass

      @Nullable public Class<T> reflectClass()
      Returns the class Jet will deserialize data into (using reflection). Null if not set.
    • format

      @Nonnull public String format()
      Description copied from interface: FileFormat
      Returns the name of the file format. The convention is to use the well-known filename suffix or, if there is none, a short-form name of the format.
      Specified by:
      format in interface FileFormat<T>