org.apache.flink.api.common.operators

Class SingleInputSemanticProperties.AllFieldsForwardedProperties

java.lang.Object

org.apache.flink.api.common.operators.SingleInputSemanticProperties

org.apache.flink.api.common.operators.SingleInputSemanticProperties.AllFieldsForwardedProperties

All Implemented Interfaces:

Serializable, SemanticProperties

Enclosing class:

SingleInputSemanticProperties

public static class SingleInputSemanticProperties.AllFieldsForwardedProperties
extends SingleInputSemanticProperties

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.operators.SingleInputSemanticProperties

SingleInputSemanticProperties.AllFieldsForwardedProperties

Nested classes/interfaces inherited from interface org.apache.flink.api.common.operators.SemanticProperties

SemanticProperties.EmptySemanticProperties, SemanticProperties.InvalidSemanticAnnotationException

Constructor Summary

Constructors

Constructor and Description
AllFieldsForwardedProperties()

Method Summary

Modifier and Type	Method and Description
void	addForwardedField(int sourceField, int targetField) Adds, to the existing information, a field that is forwarded directly from the source record(s) to the destination record(s).
int	getForwardingSourceField(int input, int targetField) Returns the index of the source field on the given input from which the target field has been unmodified copied by a function.
FieldSet	getForwardingTargetFields(int input, int sourceField) Returns the indexes of all target fields to which a source field has been unmodified copied by a function.

Methods inherited from class org.apache.flink.api.common.operators.SingleInputSemanticProperties

addReadFields, getReadFields, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

AllFieldsForwardedProperties

public AllFieldsForwardedProperties()

Method Detail

getForwardingTargetFields

public FieldSet getForwardingTargetFields(int input,
                                          int sourceField)

Description copied from interface: SemanticProperties

Returns the indexes of all target fields to which a source field has been unmodified copied by a function.

Specified by:

getForwardingTargetFields in interface SemanticProperties

Overrides:

getForwardingTargetFields in class SingleInputSemanticProperties

Parameters:

input - The input id for the requested source field (0 for first input, 1 for second input)

sourceField - The index of the field for which the target position index is requested.

Returns:

A set containing the indexes of all target fields to which the source field has been unmodified copied.

getForwardingSourceField

public int getForwardingSourceField(int input,
                                    int targetField)

Description copied from interface: SemanticProperties

Returns the index of the source field on the given input from which the target field has been unmodified copied by a function.

Specified by:

getForwardingSourceField in interface SemanticProperties

Overrides:

getForwardingSourceField in class SingleInputSemanticProperties

Parameters:

input - The input id for the requested source field (0 for first input, 1 for second input)

targetField - The index of the target field to which the source field has been copied.

Returns:

The index of the source field on the given index that was copied to the given target field. -1 if the target field was not copied from any source field of the given input.

addForwardedField

public void addForwardedField(int sourceField,
                              int targetField)

Description copied from class: SingleInputSemanticProperties

Adds, to the existing information, a field that is forwarded directly from the source record(s) to the destination record(s).

Overrides:

addForwardedField in class SingleInputSemanticProperties

Parameters:

sourceField - the position in the source record(s)

targetField - the position in the destination record(s)