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
FileFormat
for avro files. See FileFormat.avro()
for more
details.- Since:
- Jet 4.4
- See Also:
-
Field Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
format()
Returns the name of the file format.int
hashCode()
Returns the class Jet will deserialize data into (using reflection).withReflect
(Class<T> reflectClass) Specifies to use reflection to deserialize data into the given class.
-
Field Details
-
FORMAT_AVRO
Format id for Avro.- See Also:
-
-
Method Details
-
withReflect
Specifies to use reflection to deserialize data into the given class. Jet will use theReflectDatumReader
to read Avro data. The parameter may benull
, this disables the option to deserialize using reflection.- Parameters:
reflectClass
- class to deserialize data into
-
reflectClass
Returns the class Jet will deserialize data into (using reflection). Null if not set. -
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 interfaceFileFormat<T>
-
equals
-
hashCode
public int hashCode()
-