Package 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	Description
static class	CompactContext.CompactContextImpl	Implementation of CompactContext.

Method Summary

Modifier and Type	Method	Description
static CompactContext	create(org.apache.flink.configuration.Configuration config, org.apache.flink.core.fs.FileSystem fileSystem, String partition, org.apache.flink.core.fs.Path path)
org.apache.flink.configuration.Configuration	getConfig()
org.apache.flink.core.fs.FileSystem	getFileSystem()
String	getPartition()
org.apache.flink.core.fs.Path	getPath()

Method Detail

create

static CompactContext create(org.apache.flink.configuration.Configuration config,
                             org.apache.flink.core.fs.FileSystem fileSystem,
                             String partition,
                             org.apache.flink.core.fs.Path path)

getConfig

org.apache.flink.configuration.Configuration getConfig()

getFileSystem

org.apache.flink.core.fs.FileSystem getFileSystem()

getPartition

String getPartition()

getPath

org.apache.flink.core.fs.Path getPath()