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

Class MappingEntrySource

java.lang.Object

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

Direct Known Subclasses:

FileBackedMappingEntrySource, HandleBackedMappingEntrySource

public abstract class MappingEntrySource
extends Object

Indicates the source file of the MappingEntry. It may be backed either by a file or a StreamStateHandle.

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method	Description
abstract boolean	cacheable()
abstract void	delete(boolean recursive)
abstract org.apache.flink.core.fs.Path	getFilePath()
abstract long	getSize()
abstract org.apache.flink.core.fs.FSDataInputStream	openInputStream()
abstract org.apache.flink.core.fs.FSDataInputStream	openInputStream(int bufferSize)
abstract org.apache.flink.runtime.state.StreamStateHandle	toStateHandle()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Method Detail

delete

public abstract void delete(boolean recursive)
                     throws IOException

Throws:

IOException

getFilePath

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

getSize

public abstract long getSize()
                      throws IOException

Throws:

IOException

openInputStream

public abstract org.apache.flink.core.fs.FSDataInputStream openInputStream()
                                                                    throws IOException

Throws:

IOException

openInputStream

public abstract org.apache.flink.core.fs.FSDataInputStream openInputStream(int bufferSize)
                                                                    throws IOException

Throws:

IOException

cacheable

public abstract boolean cacheable()

toStateHandle

public abstract org.apache.flink.runtime.state.StreamStateHandle toStateHandle()
                                                                        throws IOException

Throws:

IOException