Package org.apache.flink.state.forst.fs.filemapping

Class FileOwnershipDecider

java.lang.Object

org.apache.flink.state.forst.fs.filemapping.FileOwnershipDecider

public class FileOwnershipDecider
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	SST_SUFFIX

Method Summary

Modifier and Type	Method	Description
static FileOwnership	decideForNewFile(org.apache.flink.core.fs.Path filePath)
static FileOwnership	decideForRestoredFile(org.apache.flink.core.fs.Path filePath)
static boolean	isSstFile(org.apache.flink.core.fs.Path filePath)
static boolean	shouldAlwaysBeLocal(org.apache.flink.core.fs.Path filePath)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SST_SUFFIX

public static final String SST_SUFFIX

See Also:

Constant Field Values

Method Detail

decideForNewFile

public static FileOwnership decideForNewFile(org.apache.flink.core.fs.Path filePath)

decideForRestoredFile

public static FileOwnership decideForRestoredFile(org.apache.flink.core.fs.Path filePath)

isSstFile

public static boolean isSstFile(org.apache.flink.core.fs.Path filePath)

shouldAlwaysBeLocal

public static boolean shouldAlwaysBeLocal(org.apache.flink.core.fs.Path filePath)