CsvRowSerializationSchema (Flink : Formats : Csv 1.20.3-cp2 API)

java.lang.Object
- org.apache.flink.formats.csv.CsvRowSerializationSchema

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
```
@PublicEvolving
@Deprecated
public final class CsvRowSerializationSchema
extends Object
implements org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
```
Deprecated.
The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own SerializationSchema.

Serialization schema that serializes an object of Flink types into a CSV bytes.
Serializes the input row into a ObjectNode and converts it into byte[].
Result byte[] messages can be deserialized using CsvRowDeserializationSchema.

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class CsvRowSerializationSchema.Builder
Deprecated.

A builder for creating a CsvRowSerializationSchema.
- Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.SerializationSchema
  org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object o)`	Deprecated.
`int`	`hashCode()`	Deprecated.
`void`	`open(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context)`	Deprecated.
`byte[]`	`serialize(org.apache.flink.types.Row row)`	Deprecated.

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - open
```
public void open(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context)
          throws Exception
```
    Deprecated.
    
    Specified by:
    
    open in interface org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
    
    Throws:
    
    Exception
  - serialize
```
public byte[] serialize(org.apache.flink.types.Row row)
```
    Deprecated.
    
    Specified by:
    
    serialize in interface org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
  - equals
```
public boolean equals(Object o)
```
    Deprecated.
    
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Deprecated.
    
    Overrides:
    
    hashCode in class Object