Package org.apache.flink.runtime.shuffle
Class ShuffleMasterContextImpl
- java.lang.Object
-
- org.apache.flink.runtime.shuffle.ShuffleMasterContextImpl
-
- All Implemented Interfaces:
ShuffleMasterContext
public class ShuffleMasterContextImpl extends Object implements ShuffleMasterContext
The default implementation ofShuffleMasterContext
.
-
-
Constructor Summary
Constructors Constructor Description ShuffleMasterContextImpl(Configuration configuration, FatalErrorHandler fatalErrorHandler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Configuration
getConfiguration()
void
onFatalError(Throwable throwable)
Handles the fatal error if any.
-
-
-
Constructor Detail
-
ShuffleMasterContextImpl
public ShuffleMasterContextImpl(Configuration configuration, FatalErrorHandler fatalErrorHandler)
-
-
Method Detail
-
getConfiguration
public Configuration getConfiguration()
- Specified by:
getConfiguration
in interfaceShuffleMasterContext
- Returns:
- the cluster configuration.
-
onFatalError
public void onFatalError(Throwable throwable)
Description copied from interface:ShuffleMasterContext
Handles the fatal error if any.- Specified by:
onFatalError
in interfaceShuffleMasterContext
-
-