Package org.apache.flink.api.java.io
Class PrintingOutputFormat<T>
- java.lang.Object
-
- org.apache.flink.api.common.io.RichOutputFormat<T>
-
- org.apache.flink.api.java.io.PrintingOutputFormat<T>
-
- Type Parameters:
T- Input record type
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.io.OutputFormat<T>
@Deprecated @PublicEvolving public class PrintingOutputFormat<T> extends org.apache.flink.api.common.io.RichOutputFormat<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.Output format that prints results into either stdout or stderr.Four possible format options:
sinkIdentifier:taskId> output <-sinkIdentifierprovided, parallelism > 1sinkIdentifier> output <-sinkIdentifierprovided, parallelism == 1 taskId> output <- nosinkIdentifierprovided, parallelism > 1 output <- nosinkIdentifierprovided, parallelism == 1
-
-
Constructor Summary
Constructors Constructor Description PrintingOutputFormat()Deprecated.Instantiates a printing output format that prints to standard out.PrintingOutputFormat(boolean stdErr)Deprecated.Instantiates a printing output format that prints to standard out.PrintingOutputFormat(String sinkIdentifier, boolean stdErr)Deprecated.Instantiates a printing output format that prints to standard out with a prefixed message.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidclose()Deprecated.voidconfigure(org.apache.flink.configuration.Configuration parameters)Deprecated.voidopen(int taskNumber, int numTasks)Deprecated.StringtoString()Deprecated.voidwriteRecord(T record)Deprecated.-
Methods inherited from class org.apache.flink.api.common.io.RichOutputFormat
getRuntimeContext, setRuntimeContext
-
-
-
-
Constructor Detail
-
PrintingOutputFormat
public PrintingOutputFormat()
Deprecated.Instantiates a printing output format that prints to standard out.
-
PrintingOutputFormat
public PrintingOutputFormat(boolean stdErr)
Deprecated.Instantiates a printing output format that prints to standard out.- Parameters:
stdErr- True, if the format should print to standard error instead of standard out.
-
PrintingOutputFormat
public PrintingOutputFormat(String sinkIdentifier, boolean stdErr)
Deprecated.Instantiates a printing output format that prints to standard out with a prefixed message.- Parameters:
sinkIdentifier- Message that is prefixed to the output of the value.stdErr- True, if the format should print to standard error instead of standard out.
-
-
Method Detail
-
configure
public void configure(org.apache.flink.configuration.Configuration parameters)
Deprecated.
-
open
public void open(int taskNumber, int numTasks)Deprecated.
-
writeRecord
public void writeRecord(T record)
Deprecated.
-
close
public void close()
Deprecated.
-
-