public class HeadOperatorFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<IterationRecord<?>> implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IterationRecord<?>,IterationRecord<?>>, org.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<IterationRecord<?>>, org.apache.flink.streaming.api.operators.YieldingOperatorFactory<IterationRecord<?>>
HeadOperator
.Constructor and Description |
---|
HeadOperatorFactory(IterationID iterationId,
int feedbackIndex,
boolean isCriteriaStream,
int totalInitialVariableParallelism) |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<?>>> |
createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<?>> streamOperatorParameters) |
org.apache.flink.streaming.api.operators.ChainingStrategy |
getChainingStrategy() |
org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider |
getCoordinatorProvider(String s,
org.apache.flink.runtime.jobgraph.OperatorID operatorID) |
Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader) |
void |
setCriteriaStreamParallelism(int criteriaStreamParallelism) |
void |
setMailboxExecutor(org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor) |
getMailboxExecutor, setChainingStrategy, setProcessingTimeService
public HeadOperatorFactory(IterationID iterationId, int feedbackIndex, boolean isCriteriaStream, int totalInitialVariableParallelism)
public void setCriteriaStreamParallelism(int criteriaStreamParallelism)
public <T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<?>>> T createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<?>> streamOperatorParameters)
createStreamOperator
in interface org.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<IterationRecord<?>>
createStreamOperator
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<IterationRecord<?>>
public org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider getCoordinatorProvider(String s, org.apache.flink.runtime.jobgraph.OperatorID operatorID)
getCoordinatorProvider
in interface org.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<IterationRecord<?>>
public Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
getStreamOperatorClass
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<IterationRecord<?>>
public void setMailboxExecutor(org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor)
setMailboxExecutor
in interface org.apache.flink.streaming.api.operators.YieldingOperatorFactory<IterationRecord<?>>
setMailboxExecutor
in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<IterationRecord<?>>
public org.apache.flink.streaming.api.operators.ChainingStrategy getChainingStrategy()
getChainingStrategy
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<IterationRecord<?>>
getChainingStrategy
in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<IterationRecord<?>>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.