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

Class MappingEntry

java.lang.Object

org.apache.flink.runtime.asyncprocessing.ReferenceCounted

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

public class MappingEntry
extends org.apache.flink.runtime.asyncprocessing.ReferenceCounted

A file mapping entry that encapsulates source and destination path. Source Path : dest Path = 1 : N.

Constructor Summary

Constructors

Constructor	Description
MappingEntry(int initReference, org.apache.flink.core.fs.Path sourcePath, FileOwnership fileOwnership, boolean isDirectory)
MappingEntry(int initReference, org.apache.flink.runtime.state.StreamStateHandle stateHandle, FileOwnership fileOwnership, boolean isDirectory)
MappingEntry(int initReference, MappingEntrySource source, FileOwnership fileOwnership, FileBasedCache cache, boolean isDirectory, boolean writing)

Method Summary

Modifier and Type	Method	Description
void	endWriting()
boolean	equals(Object o)
FileOwnership	getFileOwnership()
MappingEntrySource	getSource()
org.apache.flink.core.fs.Path	getSourcePath()
boolean	isWriting()
protected void	referenceCountReachedZero(Object o)
void	setFileOwnership(FileOwnership ownership)
void	setSource(org.apache.flink.runtime.state.StreamStateHandle stateHandle)
String	toString()

Methods inherited from class org.apache.flink.runtime.asyncprocessing.ReferenceCounted

getReferenceCount, release, release, retain, tryRetain

Methods inherited from class java.lang.Object

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

Constructor Detail

MappingEntry

public MappingEntry(int initReference,
                    org.apache.flink.runtime.state.StreamStateHandle stateHandle,
                    FileOwnership fileOwnership,
                    boolean isDirectory)

MappingEntry

public MappingEntry(int initReference,
                    org.apache.flink.core.fs.Path sourcePath,
                    FileOwnership fileOwnership,
                    boolean isDirectory)

MappingEntry

public MappingEntry(int initReference,
                    MappingEntrySource source,
                    FileOwnership fileOwnership,
                    FileBasedCache cache,
                    boolean isDirectory,
                    boolean writing)

Method Detail

setFileOwnership

public void setFileOwnership(FileOwnership ownership)

setSource

public void setSource(org.apache.flink.runtime.state.StreamStateHandle stateHandle)

getSource

public MappingEntrySource getSource()

getSourcePath

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

getFileOwnership

public FileOwnership getFileOwnership()

isWriting

public boolean isWriting()

endWriting

public void endWriting()

referenceCountReachedZero

protected void referenceCountReachedZero(@Nullable
                                         Object o)

Specified by:

referenceCountReachedZero in class org.apache.flink.runtime.asyncprocessing.ReferenceCounted

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object