Package com.hazelcast.jet.pipeline.file

Class AvroFileFormat<T>

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:

Jet 4.4

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FORMAT_AVRO	Format id for Avro.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	format()	Returns the name of the file format.
int	hashCode()
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, finalize, getClass, 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>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object