@PublicEvolving public final class CsvRowDeserializationSchema extends Object implements DeserializationSchema<Row>
Deserializes a byte[]
message as a JsonNode
and
converts it to Row
.
Failure during deserialization are forwarded as wrapped IOException
s.
Modifier and Type | Class and Description |
---|---|
static class |
CsvRowDeserializationSchema.Builder
A builder for creating a
CsvRowDeserializationSchema . |
Modifier and Type | Method and Description |
---|---|
Row |
deserialize(byte[] message)
Deserializes the byte message.
|
boolean |
equals(Object o) |
TypeInformation<Row> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
int |
hashCode() |
boolean |
isEndOfStream(Row nextElement)
Method to decide whether the element signals the end of the stream.
|
public Row deserialize(byte[] message) throws IOException
DeserializationSchema
deserialize
in interface DeserializationSchema<Row>
message
- The message, as a byte array.IOException
public boolean isEndOfStream(Row nextElement)
DeserializationSchema
isEndOfStream
in interface DeserializationSchema<Row>
nextElement
- The element to test for the end-of-stream signal.public TypeInformation<Row> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<Row>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.