Package | Description |
---|---|
org.apache.flink.runtime.shuffle |
Modifier and Type | Class and Description |
---|---|
class |
DefaultShuffleMasterSnapshotContext
Default
ShuffleMasterSnapshotContext implementation. |
Modifier and Type | Method and Description |
---|---|
default void |
ShuffleMaster.snapshotState(CompletableFuture<ShuffleMasterSnapshot> snapshotFuture,
ShuffleMasterSnapshotContext context)
Triggers a snapshot of the shuffle master's state.
|
void |
NettyShuffleMaster.snapshotState(CompletableFuture<ShuffleMasterSnapshot> snapshotFuture,
ShuffleMasterSnapshotContext context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.