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	localOffset
StreamStateHandle	localStreamHandle
long	offset
SequenceNumber	sequenceNumber
long	size
StreamStateHandle	streamStateHandle

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
long	getLocalOffset()
StreamStateHandle	getLocalStreamHandleStateHandle()
long	getOffset()
SequenceNumber	getSequenceNumber()
long	getSize()
StreamStateHandle	getStreamStateHandle()
static UploadResult	of(StreamStateHandle handle, StreamStateHandle localHandle, StateChangeSet changeSet, long offset, long localOffset)
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

localStreamHandle

@Nullable
public final StreamStateHandle localStreamHandle

offset

public final long offset

localOffset

public final long localOffset

sequenceNumber

public final SequenceNumber sequenceNumber

size

public final long size

Constructor Detail

UploadResult

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

UploadResult

public UploadResult(StreamStateHandle streamStateHandle,
                    @Nullable
                    StreamStateHandle localStreamHandle,
                    long offset,
                    long localOffset,
                    SequenceNumber sequenceNumber,
                    long size)

Method Detail

of

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

getStreamStateHandle

public StreamStateHandle getStreamStateHandle()

getLocalStreamHandleStateHandle

public StreamStateHandle getLocalStreamHandleStateHandle()

getOffset

public long getOffset()

getLocalOffset

public long getLocalOffset()

getSequenceNumber

public SequenceNumber getSequenceNumber()

getSize

public long getSize()

toString

public String toString()

Overrides:

toString in class Object