AvroFileFormat (hazelcast-jet-distribution 4.5 API)

java.lang.Object

com.hazelcast.jet.pipeline.file.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.

Since:: 4.4
See Also:: Serialized Form

Field Summary

Fields

Modifier and Type Field Description

static String FORMAT_AVRO
Format id for Avro.

Method Summary

Modifier and Type	Method	Description
`String`	`format()`	Returns the name of the file format.
`Class<T>`	`reflectClass()`	Returns the class Jet will deserialize data into (using reflection).
`AvroFileFormat<T>`	`withReflect(Class<T> reflectClass)`	Specifies to use reflection to deserialize data into the given class.

Methods inherited from class java.lang.Object

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

Field Details
- FORMAT_AVRO
  
  public static final String FORMAT_AVRO
  
  Format id for Avro.
  
  See Also:
  
  Constant Field Values
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.
  
  Parameters:
  
  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>