public static class JsonFileSystemFormatFactory.JsonRowDataEncoder extends Object implements Encoder<RowData>
JsonFileSystemFormatFactory.JsonRowDataEncoder
is responsible to encode a RowData
to OutputStream
with json format.Constructor and Description |
---|
JsonRowDataEncoder(JsonRowDataSerializationSchema serializationSchema) |
Modifier and Type | Method and Description |
---|---|
void |
encode(RowData element,
OutputStream stream)
Writes one element to the bucket file.
|
public JsonRowDataEncoder(JsonRowDataSerializationSchema serializationSchema)
public void encode(RowData element, OutputStream stream) throws IOException
Encoder
encode
in interface Encoder<RowData>
element
- the element to be written.stream
- the stream to write the element to.IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.