org.apache.flink.streaming.api.operators

Class InternalTimerServiceSerializationProxy<K,N>

java.lang.Object

org.apache.flink.core.io.VersionedIOReadableWritable

org.apache.flink.core.io.PostVersionedIOReadableWritable

org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy<K,N>

All Implemented Interfaces:

IOReadableWritable, Versioned

@Internal
public class InternalTimerServiceSerializationProxy<K,N>
extends PostVersionedIOReadableWritable

Serialization proxy for the timer services for a given key-group.

Field Summary

Fields

Modifier and Type	Field and Description
static int	VERSION

Constructor Summary

Constructors

Constructor and Description
InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServicesMapToPopulate, ClassLoader userCodeClassLoader, int totalKeyGroups, KeyGroupsList localKeyGroupRange, KeyContext keyContext, ProcessingTimeService processingTimeService, int keyGroupIdx) Constructor to use when restoring timer services.
InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServices, int keyGroupIdx) Constructor to use when writing timer services.

Method Summary

Modifier and Type	Method and Description
int	getVersion() Returns the version number of the object.
protected void	read(DataInputView in, boolean wasVersioned) Read from the provided in.
void	write(DataOutputView out) Writes the object's internal data to the given data output view.

Methods inherited from class org.apache.flink.core.io.PostVersionedIOReadableWritable

read, read

Methods inherited from class org.apache.flink.core.io.VersionedIOReadableWritable

getCompatibleVersions, getReadVersion

Methods inherited from class java.lang.Object

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

Field Detail

VERSION

public static final int VERSION

See Also:

Constant Field Values

Constructor Detail

InternalTimerServiceSerializationProxy

public InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServicesMapToPopulate,
                                              ClassLoader userCodeClassLoader,
                                              int totalKeyGroups,
                                              KeyGroupsList localKeyGroupRange,
                                              KeyContext keyContext,
                                              ProcessingTimeService processingTimeService,
                                              int keyGroupIdx)

Constructor to use when restoring timer services.

InternalTimerServiceSerializationProxy

public InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServices,
                                              int keyGroupIdx)

Constructor to use when writing timer services.

Method Detail

getVersion

public int getVersion()

Description copied from interface: Versioned

Returns the version number of the object. Versions numbers can be used to differentiate evolving classes.

write

public void write(DataOutputView out)
           throws IOException

Description copied from interface: IOReadableWritable

Writes the object's internal data to the given data output view.

Specified by:

write in interface IOReadableWritable

Overrides:

write in class PostVersionedIOReadableWritable

Parameters:

out - the output view to receive the data.

Throws:

IOException - thrown if any error occurs while writing to the output stream

read

protected void read(DataInputView in,
                    boolean wasVersioned)
             throws IOException

Description copied from class: PostVersionedIOReadableWritable

Read from the provided in. A flag wasVersioned can be used to determine whether or not the data to read was previously written by a VersionedIOReadableWritable.

Specified by:

read in class PostVersionedIOReadableWritable

Throws:

IOException