org.apache.flink.connector.file.table.stream.compact

Interface CompactContext

All Known Implementing Classes:

CompactContext.CompactContextImpl

@Internal
public interface CompactContext

Context for CompactReader and CompactWriter.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	CompactContext.CompactContextImpl Implementation of CompactContext.

Method Summary

Modifier and Type	Method and Description
static CompactContext	create(Configuration config, FileSystem fileSystem, String partition, Path path)
Configuration	getConfig()
FileSystem	getFileSystem()
String	getPartition()
Path	getPath()

Method Detail

create

static CompactContext create(Configuration config,
                             FileSystem fileSystem,
                             String partition,
                             Path path)

getConfig

Configuration getConfig()

getFileSystem

FileSystem getFileSystem()

getPartition

String getPartition()

getPath

Path getPath()