IN- The type of the elements that are being written by the sink.
@PublicEvolving public interface Encoder<IN> extends Serializable
Encoderis used by the streaming file sink to perform the actual writing of the incoming elements to the files in a bucket.
|Modifier and Type||Method and Description|
Writes one element to the bucket file.
void encode(IN element, OutputStream stream) throws IOException
element- the element to be written.
stream- the stream to write the element to.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.