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

类 OutputFormatSinkFunction<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.OutputFormatSinkFunction<IN>

类型参数:

IN - Input type

所有已实现的接口:

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

已过时。

Please use the StreamingFileSink for writing to files from a streaming program.

@PublicEvolving
 @Deprecated
public class OutputFormatSinkFunction<IN>
extends RichSinkFunction<IN>
implements org.apache.flink.api.java.typeutils.InputTypeConfigurable

Simple implementation of the SinkFunction writing tuples in the specified OutputFormat format.

另请参阅:

序列化表格

嵌套类概要

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

SinkFunction.Context

构造器概要

构造器

构造器和说明
OutputFormatSinkFunction(org.apache.flink.api.common.io.OutputFormat<IN> format) 已过时。

方法概要

限定符和类型	方法和说明
void	close() 已过时。
org.apache.flink.api.common.io.OutputFormat<IN>	getFormat() 已过时。
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).
void	setInputType(org.apache.flink.api.common.typeinfo.TypeInformation<?> type, org.apache.flink.api.common.ExecutionConfig executionConfig) 已过时。
void	setRuntimeContext(org.apache.flink.api.common.functions.RuntimeContext context) 已过时。

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

getIterationRuntimeContext, getRuntimeContext

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

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

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

finish, invoke, writeWatermark

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

open

构造器详细资料

OutputFormatSinkFunction

public OutputFormatSinkFunction(org.apache.flink.api.common.io.OutputFormat<IN> format)

已过时。

方法详细资料

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 OutputFormatSinkFunction.

指定者:

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

setRuntimeContext

public void setRuntimeContext(org.apache.flink.api.common.functions.RuntimeContext context)

已过时。

指定者:

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

覆盖:

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

setInputType

public void setInputType(org.apache.flink.api.common.typeinfo.TypeInformation<?> type,
                         org.apache.flink.api.common.ExecutionConfig executionConfig)

已过时。

指定者:

setInputType 在接口中 org.apache.flink.api.java.typeutils.InputTypeConfigurable

invoke

public void invoke(IN record)
            throws Exception

已过时。

指定者:

invoke 在接口中 SinkFunction<IN>

抛出:

Exception

close

public void close()
           throws IOException

已过时。

指定者:

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

覆盖:

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

抛出:

IOException

getFormat

public org.apache.flink.api.common.io.OutputFormat<IN> getFormat()

已过时。