public interface OperatorInfo
Modifier and Type | Method and Description |
---|---|
int |
currentParallelism() |
static Collection<OperatorID> |
getIds(Collection<? extends OperatorInfo> infos) |
int |
maxParallelism() |
OperatorID |
operatorId() |
OperatorID operatorId()
int maxParallelism()
int currentParallelism()
static Collection<OperatorID> getIds(Collection<? extends OperatorInfo> infos)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.