OUT
- The output type of the operatorpublic class AsyncWaitOperatorFactory<IN,OUT> extends Object implements OneInputStreamOperatorFactory<IN,OUT>, YieldingOperatorFactory<OUT>
AsyncWaitOperator
.Constructor and Description |
---|
AsyncWaitOperatorFactory(AsyncFunction<IN,OUT> asyncFunction,
long timeout,
int capacity,
AsyncDataStream.OutputMode outputMode) |
Modifier and Type | Method and Description |
---|---|
StreamOperator |
createStreamOperator(StreamTask containingTask,
StreamConfig config,
Output output)
Create the operator.
|
ChainingStrategy |
getChainingStrategy()
Get the chaining strategy of operator factory.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
void |
setChainingStrategy(ChainingStrategy strategy)
Set the chaining strategy for operator factory.
|
void |
setMailboxExecutor(MailboxExecutor mailboxExecutor) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isInputTypeConfigurable, isOutputTypeConfigurable, isStreamSource, setInputType, setOutputType
public AsyncWaitOperatorFactory(AsyncFunction<IN,OUT> asyncFunction, long timeout, int capacity, AsyncDataStream.OutputMode outputMode)
public void setMailboxExecutor(MailboxExecutor mailboxExecutor)
setMailboxExecutor
in interface YieldingOperatorFactory<OUT>
public StreamOperator createStreamOperator(StreamTask containingTask, StreamConfig config, Output output)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<OUT>
public void setChainingStrategy(ChainingStrategy strategy)
StreamOperatorFactory
setChainingStrategy
in interface StreamOperatorFactory<OUT>
public ChainingStrategy getChainingStrategy()
StreamOperatorFactory
getChainingStrategy
in interface StreamOperatorFactory<OUT>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<OUT>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.