Package org.apache.flink.table.runtime.operators

Class TableKeyedAsyncWaitOperatorFactory<IN,​OUT,​KEY>

  • Type Parameters:
    IN - The input type of the operator
    OUT - The output type of the operator
    KEY - The key type of the operator
    All Implemented Interfaces:
    Serializable, org.apache.flink.streaming.api.operators.legacy.YieldingOperatorFactory<OUT>, org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IN,​OUT>, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>, org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware
    public class TableKeyedAsyncWaitOperatorFactory<IN,​OUT,​KEY>
extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<OUT>
implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IN,​OUT>, org.apache.flink.streaming.api.operators.legacy.YieldingOperatorFactory<OUT>
    The factory of TableKeyedAsyncWaitOperator.
    See Also:
    Serialized Form

    • Field Summary

      • Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

        chainingStrategy, processingTimeService

    • Constructor Summary

      Constructors 
      Constructor Description
      TableKeyedAsyncWaitOperatorFactory​(org.apache.flink.streaming.api.functions.async.AsyncFunction<IN,​OUT> asyncFunction, org.apache.flink.api.java.functions.KeySelector<IN,​KEY> keySelector, long timeout, int capacity)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T extends org.apache.flink.streaming.api.operators.StreamOperator<OUT>>
      T      		 createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT> parameters)  
      Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass​(ClassLoader classLoader)  

      • Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

        getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService

      • Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory

        getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType

      • Methods inherited from interface org.apache.flink.streaming.api.operators.legacy.YieldingOperatorFactory

        setMailboxExecutor

    • Constructor Detail

      • TableKeyedAsyncWaitOperatorFactory

        public TableKeyedAsyncWaitOperatorFactory​(org.apache.flink.streaming.api.functions.async.AsyncFunction<IN,​OUT> asyncFunction,
                                          org.apache.flink.api.java.functions.KeySelector<IN,​KEY> keySelector,
                                          long timeout,
                                          int capacity)

    • Method Detail

      • createStreamOperator

        public <T extends org.apache.flink.streaming.api.operators.StreamOperator<OUT>> T createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT> parameters)
        Specified by:
        createStreamOperator in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<IN>

      • getStreamOperatorClass

        public Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass​(ClassLoader classLoader)
        Specified by:
        getStreamOperatorClass in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<IN>