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

类 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>

类型参数:

IN - Input record type

所有已实现的接口:

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

已过时。

This interface will be removed in future versions. Use the new PrintSink interface instead.

@Deprecated
 @PublicEvolving
public class PrintSinkFunction<IN>
extends RichSinkFunction<IN>
implements org.apache.flink.api.common.SupportsConcurrentExecutionAttempts

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

Four possible format options: sinkIdentifier:taskId> output <- sinkIdentifier provided, parallelism > 1 sinkIdentifier> output <- sinkIdentifier provided, parallelism == 1 taskId> output <- no sinkIdentifier provided, parallelism > 1 output <- no sinkIdentifier provided, parallelism == 1

另请参阅:

序列化表格

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.streaming.api.functions.sink.SinkFunction

SinkFunction.Context

构造器概要

构造器

构造器和说明
PrintSinkFunction() 已过时。 Instantiates a print sink function that prints to standard out.
PrintSinkFunction(boolean stdErr) 已过时。 Instantiates a print sink function that prints to standard out.
PrintSinkFunction(String sinkIdentifier, boolean stdErr) 已过时。 Instantiates a print sink function that prints to standard out and gives a sink identifier.

方法概要

限定符和类型	方法和说明
void	invoke(IN record) 已过时。
void	open(org.apache.flink.configuration.Configuration parameters) 已过时。 This method is deprecated since Flink 1.19. The users are recommended to implement open(OpenContext openContext) and override open(Configuration parameters) with an empty body instead. 1. If you implement open(OpenContext openContext), the open(OpenContext openContext) will be invoked and the open(Configuration parameters) won't be invoked. 2. If you don't implement open(OpenContext openContext), the open(Configuration parameters) will be invoked in the default implementation of the open(OpenContext openContext).
String	toString() 已过时。

从类继承的方法 org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.flink.streaming.api.functions.sink.SinkFunction

finish, invoke, writeWatermark

从接口继承的方法 org.apache.flink.api.common.functions.RichFunction

open

构造器详细资料

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.

参数:

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

PrintSinkFunction

public PrintSinkFunction(String sinkIdentifier,
                         boolean stdErr)

已过时。

Instantiates a print sink function that prints to standard out and gives a sink identifier.

参数:

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

sinkIdentifier - Message that identify sink and is prefixed to the output of the value

方法详细资料

open

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

已过时。 This method is deprecated since Flink 1.19. The users are recommended to implement open(OpenContext openContext) and override open(Configuration parameters) with an empty body instead. 1. If you implement open(OpenContext openContext), the open(OpenContext openContext) will be invoked and the open(Configuration parameters) won't be invoked. 2. If you don't implement open(OpenContext openContext), the open(Configuration parameters) will be invoked in the default implementation of the open(OpenContext openContext).

Initialization method for the PrintSinkFunction.

指定者:

open 在接口中 org.apache.flink.api.common.functions.RichFunction

覆盖:

open 在类中 org.apache.flink.api.common.functions.AbstractRichFunction

参数:

parameters - The configuration containing the parameters attached to the contract.

抛出:

Exception - if an error happens.

另请参阅:

FLIP-344: Remove parameter in RichFunction#open

invoke

public void invoke(IN record)

已过时。

指定者:

invoke 在接口中 SinkFunction<IN>

toString

public String toString()

已过时。

覆盖:

toString 在类中 Object