SimpleStringDecoder (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.connector.file.sink.compactor.SimpleStringDecoder

All Implemented Interfaces:

Serializable, DecoderBasedReader.Decoder<String>
```
@PublicEvolving
public class SimpleStringDecoder
extends Object
implements DecoderBasedReader.Decoder<String>
```
A sink DecoderBasedReader.Decoder that reads data encoded by the SimpleStringEncoder only for compaction. The original input type is missing, but it's enough to read string contents for writing the compacted file.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.connector.file.sink.compactor.DecoderBasedReader.Decoder
  DecoderBasedReader.Decoder.Factory<T>

Constructor Summary

Constructors
Constructor Description

SimpleStringDecoder()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`	Closes the open resources.
`String`	`decodeNext()`
`void`	`open(InputStream input)`	Prepares to start decoding the input stream.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - SimpleStringDecoder
```
public SimpleStringDecoder()
```
- Method Detail
  - open
```
public void open(InputStream input)
          throws IOException
```
    Description copied from interface: DecoderBasedReader.Decoder
    
    Prepares to start decoding the input stream.
    
    Specified by:
    
    open in interface DecoderBasedReader.Decoder<String>
    
    Throws:
    
    IOException
  - decodeNext
```
public String decodeNext()
                  throws IOException
```
    Specified by:
    
    decodeNext in interface DecoderBasedReader.Decoder<String>
    
    Returns:
    
    The next record that decoded from the opened input stream, or null if no more available.
    
    Throws:
    
    IOException
  - close
```
public void close()
           throws IOException
```
    Description copied from interface: DecoderBasedReader.Decoder
    
    Closes the open resources. The decoder is responsible to close the input stream.
    
    Specified by:
    
    close in interface DecoderBasedReader.Decoder<String>
    
    Throws:
    
    IOException