com.hazelcast.jet.pipeline.file

Class CsvFileFormat<T>

java.lang.Object

com.hazelcast.jet.pipeline.file.CsvFileFormat<T>

Type Parameters:

T - type of items a source using this file format will emit

All Implemented Interfaces:

FileFormat<T>, Serializable

public class CsvFileFormat<T>
extends Object
implements FileFormat<T>

FileFormat for CSV files. See FileFormat.csv(java.util.List<java.lang.String>) for more details.

Since:

Jet 4.4

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	FORMAT_CSV Format ID for CSV.

Method Summary

Modifier and Type	Method and Description
Class<T>	clazz() Returns the class Jet will deserialize data into.
boolean	equals(Object o)
List<String>	fieldNames() Return the desired list of fields that is used with String[] class.
String	format() Returns the name of the file format.
int	hashCode()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.jet.pipeline.file.FileFormat

avro, avro, bytes, csv, csv, json, json, lines, lines, parquet, text, text

Field Detail

FORMAT_CSV

public static final String FORMAT_CSV

Format ID for CSV.

See Also:

Constant Field Values

Method Detail

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>

clazz

@Nonnull
public Class<T> clazz()

Returns the class Jet will deserialize data into.

fieldNames

@Nullable
public List<String> fieldNames()

Return the desired list of fields that is used with String[] class.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object