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

Class FileBackedMappingEntrySource

java.lang.Object

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

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

public class FileBackedMappingEntrySource
extends MappingEntrySource

A MappingEntrySource backed by a Path.

Field Summary

Fields inherited from class org.apache.flink.state.forst.fs.filemapping.MappingEntrySource

LOG

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

delete

public void delete(boolean recursive)
            throws IOException

Specified by:

delete in class MappingEntrySource

Throws:

IOException

getFilePath

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

Specified by:

getFilePath in class MappingEntrySource

getSize

public long getSize()
             throws IOException

Specified by:

getSize in class MappingEntrySource

Throws:

IOException

openInputStream

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

Specified by:

openInputStream in class MappingEntrySource

Throws:

IOException

openInputStream

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

Specified by:

openInputStream in class MappingEntrySource

Throws:

IOException

cacheable

public boolean cacheable()

Specified by:

cacheable in class MappingEntrySource

toStateHandle

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

Specified by:

toStateHandle in class MappingEntrySource

Throws:

IOException