Encoder (Flink : Core 1.20.2-cp1 API)

Type Parameters:

IN - The type of the elements that are being written by the sink.

All Superinterfaces:

Serializable

All Known Implementing Classes:

SimpleStringEncoder
```
@PublicEvolving
public interface Encoder<IN>
extends Serializable
```
A Encoder is used by the streaming file sink to perform the actual writing of the incoming elements to the files in a bucket.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  void encode(IN element, OutputStream stream)
  Writes one element to the bucket file.

- Method Detail
  - encode
```
void encode(IN element,
            OutputStream stream)
     throws IOException
```
    Writes one element to the bucket file.
    
    Parameters:
    
    element - the element to be written.
    
    stream - the stream to write the element to.
    
    Throws:
    
    IOException