IN
- The type of the elements that are being written by the sink.@PublicEvolving public interface Encoder<IN> extends Serializable
Encoder
is 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 |
---|---|
void |
encode(IN element,
OutputStream stream)
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.IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.