Class CompactContext.CompactContextImpl
- java.lang.Object
-
- org.apache.flink.connector.file.table.stream.compact.CompactContext.CompactContextImpl
-
- All Implemented Interfaces:
CompactContext
- Enclosing interface:
- CompactContext
public static class CompactContext.CompactContextImpl extends Object implements CompactContext
Implementation ofCompactContext.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.connector.file.table.stream.compact.CompactContext
CompactContext.CompactContextImpl
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.configuration.ConfigurationgetConfig()org.apache.flink.core.fs.FileSystemgetFileSystem()StringgetPartition()org.apache.flink.core.fs.PathgetPath()
-
-
-
Method Detail
-
getConfig
public org.apache.flink.configuration.Configuration getConfig()
- Specified by:
getConfigin interfaceCompactContext
-
getFileSystem
public org.apache.flink.core.fs.FileSystem getFileSystem()
- Specified by:
getFileSystemin interfaceCompactContext
-
getPartition
public String getPartition()
- Specified by:
getPartitionin interfaceCompactContext
-
getPath
public org.apache.flink.core.fs.Path getPath()
- Specified by:
getPathin interfaceCompactContext
-
-