org.apache.flink.statefun.flink.core.feedback

Class FeedbackKey<V>

java.lang.Object

org.apache.flink.statefun.flink.core.feedback.FeedbackKey<V>

All Implemented Interfaces:

java.io.Serializable

public final class FeedbackKey<V>
extends java.lang.Object
implements java.io.Serializable

A FeedbackKey without runtime information.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FeedbackKey(java.lang.String pipelineName, long invocationId)

Method Summary

Modifier and Type	Method and Description
java.lang.String	asColocationKey()
boolean	equals(java.lang.Object o)
int	hashCode()
SubtaskFeedbackKey<V>	withSubTaskIndex(int subTaskIndex, int attemptId)

Methods inherited from class java.lang.Object

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

Constructor Detail

FeedbackKey

public FeedbackKey(java.lang.String pipelineName,
                   long invocationId)

Method Detail

withSubTaskIndex

public SubtaskFeedbackKey<V> withSubTaskIndex(int subTaskIndex,
                                              int attemptId)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

asColocationKey

public java.lang.String asColocationKey()