org.apache.flink.streaming.api.functions.sink

Class PrintSinkFunction<IN>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.sink.RichSinkFunction<IN>

org.apache.flink.streaming.api.functions.sink.PrintSinkFunction<IN>

Type Parameters:

IN - Input record type

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, SinkFunction<IN>

@PublicEvolving
public class PrintSinkFunction<IN>
extends RichSinkFunction<IN>

Implementation of the SinkFunction writing every tuple to the standard output or standard error stream.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

SinkFunction.Context<T>

Constructor Summary

Constructors

Constructor and Description
PrintSinkFunction() Instantiates a print sink function that prints to standard out.
PrintSinkFunction(boolean stdErr) Instantiates a print sink function that prints to standard out.

Method Summary

Modifier and Type	Method and Description
void	close()
void	invoke(IN record)
void	open(org.apache.flink.configuration.Configuration parameters)
void	setTargetToStandardErr()
void	setTargetToStandardOut()
String	toString()

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

invoke

Constructor Detail

PrintSinkFunction

public PrintSinkFunction()

Instantiates a print sink function that prints to standard out.

PrintSinkFunction

public PrintSinkFunction(boolean stdErr)

Instantiates a print sink function that prints to standard out.

Parameters:

stdErr - True, if the format should print to standard error instead of standard out.

Method Detail

setTargetToStandardOut

public void setTargetToStandardOut()

setTargetToStandardErr

public void setTargetToStandardErr()

open

public void open(org.apache.flink.configuration.Configuration parameters)
          throws Exception

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception

invoke

public void invoke(IN record)

close

public void close()

Specified by:

close in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

close in class org.apache.flink.api.common.functions.AbstractRichFunction

toString

public String toString()

Overrides:

toString in class Object