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)
static boolean	shouldAlwaysBeLocal(org.apache.flink.core.fs.Path filePath, FileOwnership fileOwnership)

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,
                                          FileOwnership fileOwnership)

shouldAlwaysBeLocal

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