org.apache.flink.changelog.fs

Class UploadResult

java.lang.Object

org.apache.flink.changelog.fs.UploadResult

@Internal
public final class UploadResult
extends Object

Result of uploading state changes.

Field Summary

Fields

Modifier and Type	Field and Description
long	offset
SequenceNumber	sequenceNumber
long	size
StreamStateHandle	streamStateHandle

Constructor Summary

Constructors

Constructor and Description
UploadResult(StreamStateHandle streamStateHandle, long offset, SequenceNumber sequenceNumber, long size)

Method Summary

Modifier and Type	Method and Description
long	getOffset()
SequenceNumber	getSequenceNumber()
long	getSize()
StreamStateHandle	getStreamStateHandle()
static UploadResult	of(StreamStateHandle handle, StateChangeSet changeSet, long offset)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

streamStateHandle

public final StreamStateHandle streamStateHandle

offset

public final long offset

sequenceNumber

public final SequenceNumber sequenceNumber

size

public final long size

Constructor Detail

UploadResult

public UploadResult(StreamStateHandle streamStateHandle,
                    long offset,
                    SequenceNumber sequenceNumber,
                    long size)

Method Detail

of

public static UploadResult of(StreamStateHandle handle,
                              StateChangeSet changeSet,
                              long offset)

getStreamStateHandle

public StreamStateHandle getStreamStateHandle()

getOffset

public long getOffset()

getSequenceNumber

public SequenceNumber getSequenceNumber()

getSize

public long getSize()

toString

public String toString()

Overrides:

toString in class Object