Package org.apache.flink.api.common.functions.util

Class PrintSinkOutputWriter<IN>

java.lang.Object

org.apache.flink.api.common.functions.util.PrintSinkOutputWriter<IN>

All Implemented Interfaces:

Serializable, AutoCloseable, SinkWriter<IN>

@Internal
public class PrintSinkOutputWriter<IN>
extends Object
implements Serializable, SinkWriter<IN>

Print sink output writer for DataStream and DataSet print API.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

SinkWriter.Context

Constructor Summary

Constructors

Constructor	Description
PrintSinkOutputWriter()
PrintSinkOutputWriter(boolean stdErr)
PrintSinkOutputWriter(String sinkIdentifier, boolean stdErr)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush(boolean endOfInput)	Called on checkpoint or end of input so that the writer to flush all pending data for at-least-once.
void	open(int subtaskIndex, int numParallelSubtasks)
String	toString()
void	write(IN record)
void	write(IN element, SinkWriter.Context context)	Adds an element to the writer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

writeWatermark

Constructor Detail

PrintSinkOutputWriter

public PrintSinkOutputWriter()

PrintSinkOutputWriter

public PrintSinkOutputWriter(boolean stdErr)

PrintSinkOutputWriter

public PrintSinkOutputWriter(String sinkIdentifier,
                             boolean stdErr)

Method Detail

open

public void open(int subtaskIndex,
                 int numParallelSubtasks)

write

public void write(IN record)

write

public void write(IN element,
                  SinkWriter.Context context)
           throws IOException,
                  InterruptedException

Description copied from interface: SinkWriter

Adds an element to the writer.

Specified by:

write in interface SinkWriter<IN>

Parameters:

element - The input record

context - The additional information about the input record

Throws:

IOException - if fail to add an element.

InterruptedException

flush

public void flush(boolean endOfInput)
           throws IOException,
                  InterruptedException

Description copied from interface: SinkWriter

Called on checkpoint or end of input so that the writer to flush all pending data for at-least-once.

Specified by:

flush in interface SinkWriter<IN>

Throws:

IOException

InterruptedException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object