Package org.apache.flink.state.api

Class OneInputOperatorTransformation<T>

  • Type Parameters:
    T - The type of the elements in this operator.
    @PublicEvolving
@Deprecated
public class OneInputOperatorTransformation<T>
extends Object
    Deprecated.
    Use OneInputStateTransformation instead.
    OneInputOperatorTransformation represents a user defined transformation applied on an OperatorTransformation with one input.

    • Method Detail

      • setMaxParallelism

        @PublicEvolving
public OneInputOperatorTransformation<T> setMaxParallelism​(int maxParallelism)
        Deprecated.
        Sets the maximum parallelism of this operator.

        The maximum parallelism specifies the upper bound for dynamic scaling. It also defines the number of key groups used for partitioned state.

        Parameters:
        maxParallelism - Maximum parallelism
        Returns:
        The operator with set maximum parallelism

      • assignTimestamps

        public OneInputOperatorTransformation<T> assignTimestamps​(Timestamper<T> timestamper)
        Deprecated.
        Assigns an event time timestamp to each record. This value will be used when performing event time computations such as assigning windows.

      • assignTimestamps

        public OneInputOperatorTransformation<T> assignTimestamps​(org.apache.flink.streaming.api.functions.TimestampAssigner<T> assigner)
        Deprecated.
        Assigns an event time timestamp to each record. This value will be used when performing event time computations such as assigning windows.

      • transform

        public BootstrapTransformation<T> transform​(SavepointWriterOperatorFactory factory)
        Deprecated.
        Method for passing user defined operators along with the type information that will transform the OperatorTransformation.

        IMPORTANT: Any output from this operator will be discarded.

        Parameters:
        factory - A factory returning transformation logic type of the return stream
        Returns:
        An BootstrapTransformation that can be added to a Savepoint.

      • keyBy

        public <K> KeyedOperatorTransformation<K,​T> keyBy​(org.apache.flink.api.java.functions.KeySelector<T,​K> keySelector)
        Deprecated.
        It creates a new KeyedOperatorTransformation that uses the provided key for partitioning its operator states.
        Parameters:
        keySelector - The KeySelector to be used for extracting the key for partitioning.
        Returns:
        The BootstrapTransformation with partitioned state.

      • keyBy

        public <K> KeyedOperatorTransformation<K,​T> keyBy​(org.apache.flink.api.java.functions.KeySelector<T,​K> keySelector,
                                                        org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType)
        Deprecated.
        It creates a new KeyedOperatorTransformation that uses the provided key with explicit type information for partitioning its operator states.
        Parameters:
        keySelector - The KeySelector to be used for extracting the key for partitioning.
        keyType - The type information describing the key type.
        Returns:
        The BootstrapTransformation with partitioned state.

      • keyBy

        public KeyedOperatorTransformation<org.apache.flink.api.java.tuple.Tuple,​T> keyBy​(int... fields)
        Deprecated.
        Partitions the operator state of a OperatorTransformation by the given key positions.
        Parameters:
        fields - The position of the fields on which the OperatorTransformation will be grouped.
        Returns:
        The OperatorTransformation with partitioned state.

      • keyBy

        public KeyedOperatorTransformation<org.apache.flink.api.java.tuple.Tuple,​T> keyBy​(String... fields)
        Deprecated.
        Partitions the operator state of a OperatorTransformation using field expressions. A field expression is either the name of a public field or a getter method with parentheses of the OperatorTransformation's underlying type. A dot can be used to drill down into objects, as in "field1.getInnerField2()" .
        Parameters:
        fields - One or more field expressions on which the state of the OperatorTransformation operators will be partitioned.
        Returns:
        The OperatorTransformation with partitioned state (i.e. KeyedStream)