OUT
- The output type of the operatorpublic class AsyncWaitOperatorFactory<IN,OUT> extends AbstractStreamOperatorFactory<OUT> implements OneInputStreamOperatorFactory<IN,OUT>, YieldingOperatorFactory<OUT>
AsyncWaitOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
AsyncWaitOperatorFactory(AsyncFunction<IN,OUT> asyncFunction,
long timeout,
int capacity,
AsyncDataStream.OutputMode outputMode) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<OUT>> |
createStreamOperator(StreamOperatorParameters<OUT> parameters)
Create the operator.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
void |
setMailboxExecutor(MailboxExecutor mailboxExecutor) |
getChainingStrategy, setChainingStrategy, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChainingStrategy, isInputTypeConfigurable, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, 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 <T extends StreamOperator<OUT>> T createStreamOperator(StreamOperatorParameters<OUT> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<OUT>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<OUT>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.