Package org.apache.flink.state.forst

Class ForStPathContainer

java.lang.Object

org.apache.flink.state.forst.ForStPathContainer

public class ForStPathContainer
extends Object

Container for ForSt paths.

Field Summary

Fields

Modifier and Type	Field	Description
static String	DB_DIR_STRING

Constructor Summary

Constructors

Constructor	Description
ForStPathContainer(org.apache.flink.core.fs.Path localJobPath, org.apache.flink.core.fs.Path localBasePath, org.apache.flink.core.fs.Path remoteJobPath, org.apache.flink.core.fs.Path remoteBasePath)

Method Summary

Modifier and Type	Method	Description
static ForStPathContainer	empty()
boolean	equals(Object o)
org.apache.flink.core.fs.Path	getBasePath()
org.apache.flink.core.fs.Path	getDbPath()
org.apache.flink.core.fs.Path	getJobPath()
org.apache.flink.core.fs.Path	getLocalBasePath()
org.apache.flink.core.fs.Path	getLocalForStPath()
org.apache.flink.core.fs.Path	getLocalJobPath()
org.apache.flink.core.fs.Path	getRemoteBasePath()
org.apache.flink.core.fs.Path	getRemoteForStPath()
org.apache.flink.core.fs.Path	getRemoteJobPath()
int	hashCode()
static ForStPathContainer	of(org.apache.flink.core.fs.Path localJobPath, org.apache.flink.core.fs.Path localBasePath, org.apache.flink.core.fs.Path remoteJobPath, org.apache.flink.core.fs.Path remoteBasePath)
static ForStPathContainer	ofLocal(org.apache.flink.core.fs.Path localJobPath, org.apache.flink.core.fs.Path localBasePath)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

DB_DIR_STRING

public static final String DB_DIR_STRING

See Also:

Constant Field Values

Constructor Detail

ForStPathContainer

public ForStPathContainer(@Nullable
                          org.apache.flink.core.fs.Path localJobPath,
                          @Nullable
                          org.apache.flink.core.fs.Path localBasePath,
                          @Nullable
                          org.apache.flink.core.fs.Path remoteJobPath,
                          @Nullable
                          org.apache.flink.core.fs.Path remoteBasePath)

Method Detail

empty

public static ForStPathContainer empty()

ofLocal

public static ForStPathContainer ofLocal(@Nullable
                                         org.apache.flink.core.fs.Path localJobPath,
                                         @Nullable
                                         org.apache.flink.core.fs.Path localBasePath)

of

public static ForStPathContainer of(@Nullable
                                    org.apache.flink.core.fs.Path localJobPath,
                                    @Nullable
                                    org.apache.flink.core.fs.Path localBasePath,
                                    @Nullable
                                    org.apache.flink.core.fs.Path remoteJobPath,
                                    @Nullable
                                    org.apache.flink.core.fs.Path remoteBasePath)

getLocalJobPath

@Nullable
public org.apache.flink.core.fs.Path getLocalJobPath()

getLocalBasePath

@Nullable
public org.apache.flink.core.fs.Path getLocalBasePath()

getLocalForStPath

@Nullable
public org.apache.flink.core.fs.Path getLocalForStPath()

getRemoteJobPath

@Nullable
public org.apache.flink.core.fs.Path getRemoteJobPath()

getRemoteBasePath

@Nullable
public org.apache.flink.core.fs.Path getRemoteBasePath()

getRemoteForStPath

@Nullable
public org.apache.flink.core.fs.Path getRemoteForStPath()

getJobPath

public org.apache.flink.core.fs.Path getJobPath()

getBasePath

public org.apache.flink.core.fs.Path getBasePath()

getDbPath

public org.apache.flink.core.fs.Path getDbPath()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object