Package | Description |
---|---|
org.apache.flink.runtime.shuffle |
Modifier and Type | Class and Description |
---|---|
class |
JobShuffleContextImpl
The default implementation of
JobShuffleContext . |
Modifier and Type | Method and Description |
---|---|
default void |
ShuffleMaster.registerJob(JobShuffleContext context)
Registers the target job together with the corresponding
JobShuffleContext to this
shuffle master. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.