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

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

Print sink output writer for DataStream and DataSet print API.

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	open(int subtaskIndex, int numParallelSubtasks)
String	toString()
void	write(IN record)

Methods inherited from class java.lang.Object

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

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)

toString

public String toString()

Overrides:

toString in class Object