Package org.apache.flink.table.runtime.operators.join.stream.keyselector

Class AttributeBasedJoinKeyExtractor.ConditionAttributeRef

java.lang.Object

org.apache.flink.table.runtime.operators.join.stream.keyselector.AttributeBasedJoinKeyExtractor.ConditionAttributeRef

All Implemented Interfaces:

Serializable

Enclosing class:

AttributeBasedJoinKeyExtractor

public static final class AttributeBasedJoinKeyExtractor.ConditionAttributeRef
extends Object
implements Serializable

Reference to a specific field (fieldIndex) within a specific input stream (inputId).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
int	leftFieldIndex
int	leftInputId
int	rightFieldIndex
int	rightInputId

Constructor Summary

Constructors

Constructor	Description
ConditionAttributeRef()
ConditionAttributeRef(int leftInputId, int leftFieldIndex, int rightInputId, int rightFieldIndex)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

leftInputId

public int leftInputId

leftFieldIndex

public int leftFieldIndex

rightInputId

public int rightInputId

rightFieldIndex

public int rightFieldIndex

Constructor Detail

ConditionAttributeRef

public ConditionAttributeRef()

ConditionAttributeRef

public ConditionAttributeRef(int leftInputId,
                             int leftFieldIndex,
                             int rightInputId,
                             int rightFieldIndex)

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object