org.apache.flink.streaming.api.functions.sink.filesystem

Interface PartFileInfo<BucketID>

All Known Subinterfaces:

InProgressFileWriter<IN,BucketID>

All Known Implementing Classes:

AbstractPartFileWriter, HadoopPathBasedPartFileWriter, OutputStreamBasedPartFileWriter, RowWisePartWriter

@PublicEvolving
public interface PartFileInfo<BucketID>

An interface exposing the information concerning the current (open) part file that is necessary to the RollingPolicy in order to determine if it should roll the part file or not.

Method Summary

Modifier and Type	Method and Description
BucketID	getBucketId()
long	getCreationTime()
long	getLastUpdateTime()
long	getSize()

Method Detail

getBucketId

BucketID getBucketId()

Returns:

The bucket identifier of the current buffer, as returned by the BucketAssigner.getBucketId(Object, BucketAssigner.Context).

getCreationTime

long getCreationTime()

Returns:

The creation time (in ms) of the currently open part file.

getSize

long getSize()
      throws IOException

Returns:

The size of the currently open part file.

Throws:

IOException

getLastUpdateTime

long getLastUpdateTime()

Returns:

The last time (in ms) the currently open part file was written to.