Package org.apache.flink.api.java.io

Class DiscardingOutputFormat<T>

java.lang.Object

org.apache.flink.api.java.io.DiscardingOutputFormat<T>

Type Parameters:

T - The type of the elements accepted by the output format.

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.io.OutputFormat<T>

@Deprecated
@Public
public class DiscardingOutputFormat<T>
extends Object
implements org.apache.flink.api.common.io.OutputFormat<T>

Deprecated.

All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.

An output format that simply discards all elements.

See Also:

FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API, Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.common.io.OutputFormat

org.apache.flink.api.common.io.OutputFormat.InitializationContext

Constructor Summary

Constructors

Constructor	Description
DiscardingOutputFormat()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	close()	Deprecated.
void	configure(org.apache.flink.configuration.Configuration parameters)	Deprecated.
void	open(int taskNumber, int numTasks)	Deprecated.
void	writeRecord(T record)	Deprecated.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.io.OutputFormat

open

Constructor Detail

DiscardingOutputFormat

public DiscardingOutputFormat()

Deprecated.

Method Detail

configure

public void configure(org.apache.flink.configuration.Configuration parameters)

Deprecated.

Specified by:

configure in interface org.apache.flink.api.common.io.OutputFormat<T>

open

public void open(int taskNumber,
                 int numTasks)

Deprecated.

Specified by:

open in interface org.apache.flink.api.common.io.OutputFormat<T>

writeRecord

public void writeRecord(T record)

Deprecated.

Specified by:

writeRecord in interface org.apache.flink.api.common.io.OutputFormat<T>

close

public void close()

Deprecated.

Specified by:

close in interface org.apache.flink.api.common.io.OutputFormat<T>