Package org.apache.wayang.flink.compiler

Class OutputFormatConsumer<T>

java.lang.Object

org.apache.wayang.flink.compiler.OutputFormatConsumer<T>

All Implemented Interfaces:

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

public class OutputFormatConsumer<T>
extends Object
implements org.apache.flink.api.common.io.OutputFormat<T>, Serializable

Wrapper for

See Also:

• 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
OutputFormatConsumer(FunctionDescriptor.SerializableConsumer<T> consumer)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(org.apache.flink.configuration.Configuration configuration)
void	open(int i, int i1)
void	writeRecord(T o)

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 Details

OutputFormatConsumer

public OutputFormatConsumer(FunctionDescriptor.SerializableConsumer<T> consumer)

Method Details

configure

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

Specified by:

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

open

public void open(int i,
 int i1)
          throws IOException

Specified by:

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

Throws:

IOException

writeRecord

public void writeRecord(T o)
                 throws IOException

Specified by:

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

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

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

Throws:

IOException