Package org.apache.flink.cdc.runtime.partitioning

Class PostPartitionProcessor

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichMapFunction<PartitioningEvent,Event>

org.apache.flink.cdc.runtime.partitioning.PostPartitionProcessor

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<PartitioningEvent,Event>, org.apache.flink.api.common.functions.RichFunction

@Internal
public class PostPartitionProcessor
extends org.apache.flink.api.common.functions.RichMapFunction<PartitioningEvent,Event>

Function for unloading Event from internal PartitioningEvent after EventPartitioner.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
PostPartitionProcessor()

Method Summary

Modifier and Type	Method	Description
Event	map(PartitioningEvent value)

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

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.functions.RichFunction

open

Constructor Detail

PostPartitionProcessor

public PostPartitionProcessor()

Method Detail

map

public Event map(PartitioningEvent value)
          throws Exception

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<PartitioningEvent,Event>

Specified by:

map in class org.apache.flink.api.common.functions.RichMapFunction<PartitioningEvent,Event>

Throws:

Exception