public class WrapperOperatorFactory<OUT> extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<IterationRecord<OUT>>
AbstractWrapperOperator
.Constructor and Description |
---|
WrapperOperatorFactory(org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory,
OperatorWrapper<OUT,IterationRecord<OUT>> wrapper) |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<OUT>>> |
createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters) |
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> |
getOperatorFactory() |
Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader) |
OperatorWrapper<OUT,IterationRecord<OUT>> |
getWrapper() |
getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService
public WrapperOperatorFactory(org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory, OperatorWrapper<OUT,IterationRecord<OUT>> wrapper)
public <T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<OUT>>> T createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters)
public Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
@VisibleForTesting public org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> getOperatorFactory()
@VisibleForTesting public OperatorWrapper<OUT,IterationRecord<OUT>> getWrapper()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.