Class TokenFullSyncState
-
- All Implemented Interfaces:
-
java.io.Externalizable
,java.io.Serializable
,java.lang.Comparable
,org.apache.avro.generic.GenericContainer
,org.apache.avro.generic.GenericRecord
,org.apache.avro.generic.IndexedRecord
,org.apache.avro.specific.SpecificRecord
public class TokenFullSyncState extends SpecificRecordBase implements SpecificRecord
The state of a full synchronization process
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public class
TokenFullSyncState.Builder
RecordBuilder for TokenFullSyncState instances.
-
Field Summary
Fields Modifier and Type Field Description public final static Schema
SCHEMA$
public Instant
startedTimestamp
public Instant
lastBlockCompletedTimestamp
public int
blocksCompleted
public int
recordsCompleted
public Instant
nextBlockStartOffset
-
Constructor Summary
Constructors Constructor Description TokenFullSyncState()
Default constructor. TokenFullSyncState(Instant startedTimestamp, Instant lastBlockCompletedTimestamp, Integer blocksCompleted, Integer recordsCompleted, Instant nextBlockStartOffset)
All-args constructor.
-
Method Summary
Modifier and Type Method Description Instant
getStartedTimestamp()
Gets the value of the 'startedTimestamp' field. void
setStartedTimestamp(Instant value)
Sets the value of the 'startedTimestamp' field. Instant
getLastBlockCompletedTimestamp()
Gets the value of the 'lastBlockCompletedTimestamp' field. void
setLastBlockCompletedTimestamp(Instant value)
Sets the value of the 'lastBlockCompletedTimestamp' field. int
getBlocksCompleted()
Gets the value of the 'blocksCompleted' field. void
setBlocksCompleted(int value)
Sets the value of the 'blocksCompleted' field. int
getRecordsCompleted()
Gets the value of the 'recordsCompleted' field. void
setRecordsCompleted(int value)
Sets the value of the 'recordsCompleted' field. Instant
getNextBlockStartOffset()
Gets the value of the 'nextBlockStartOffset' field. void
setNextBlockStartOffset(Instant value)
Sets the value of the 'nextBlockStartOffset' field. static Schema
getClassSchema()
static BinaryMessageEncoder<TokenFullSyncState>
getEncoder()
Return the BinaryMessageEncoder instance used by this class. static BinaryMessageDecoder<TokenFullSyncState>
getDecoder()
Return the BinaryMessageDecoder instance used by this class. static BinaryMessageDecoder<TokenFullSyncState>
createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore. ByteBuffer
toByteBuffer()
Serializes this TokenFullSyncState to a ByteBuffer. static TokenFullSyncState
fromByteBuffer(ByteBuffer b)
Deserializes a TokenFullSyncState from a ByteBuffer. SpecificData
getSpecificData()
Schema
getSchema()
Object
get(int field$)
Conversion<out Object>
getConversion(int field)
void
put(int field$, Object value$)
static TokenFullSyncState.Builder
newBuilder()
Creates a new TokenFullSyncState RecordBuilder. static TokenFullSyncState.Builder
newBuilder(TokenFullSyncState.Builder other)
Creates a new TokenFullSyncState RecordBuilder by copying an existing Builder. static TokenFullSyncState.Builder
newBuilder(TokenFullSyncState other)
Creates a new TokenFullSyncState RecordBuilder by copying an existing TokenFullSyncState instance. void
writeExternal(ObjectOutput out)
void
readExternal(ObjectInput in)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, customDecode, customEncode, equals, hashCode, toString
-
Methods inherited from class org.apache.avro.generic.GenericRecord
hasField
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
TokenFullSyncState
TokenFullSyncState()
Default constructor.
-
TokenFullSyncState
TokenFullSyncState(Instant startedTimestamp, Instant lastBlockCompletedTimestamp, Integer blocksCompleted, Integer recordsCompleted, Instant nextBlockStartOffset)
All-args constructor.- Parameters:
startedTimestamp
- The date and time the last full synchronization completed.lastBlockCompletedTimestamp
- The date and time the last full synchronization completed.blocksCompleted
- The number of blocks completedrecordsCompleted
- The number of records completednextBlockStartOffset
- The (inclusive) timestamp to start reading the next block of records
-
-
Method Detail
-
getStartedTimestamp
Instant getStartedTimestamp()
Gets the value of the 'startedTimestamp' field.
-
setStartedTimestamp
void setStartedTimestamp(Instant value)
Sets the value of the 'startedTimestamp' field. The date and time the last full synchronization completed.
- Parameters:
value
- the value to set.
-
getLastBlockCompletedTimestamp
Instant getLastBlockCompletedTimestamp()
Gets the value of the 'lastBlockCompletedTimestamp' field.
-
setLastBlockCompletedTimestamp
void setLastBlockCompletedTimestamp(Instant value)
Sets the value of the 'lastBlockCompletedTimestamp' field. The date and time the last full synchronization completed.
- Parameters:
value
- the value to set.
-
getBlocksCompleted
int getBlocksCompleted()
Gets the value of the 'blocksCompleted' field.
-
setBlocksCompleted
void setBlocksCompleted(int value)
Sets the value of the 'blocksCompleted' field. The number of blocks completed
- Parameters:
value
- the value to set.
-
getRecordsCompleted
int getRecordsCompleted()
Gets the value of the 'recordsCompleted' field.
-
setRecordsCompleted
void setRecordsCompleted(int value)
Sets the value of the 'recordsCompleted' field. The number of records completed
- Parameters:
value
- the value to set.
-
getNextBlockStartOffset
Instant getNextBlockStartOffset()
Gets the value of the 'nextBlockStartOffset' field.
-
setNextBlockStartOffset
void setNextBlockStartOffset(Instant value)
Sets the value of the 'nextBlockStartOffset' field. The (inclusive) timestamp to start reading the next block of records
- Parameters:
value
- the value to set.
-
getClassSchema
static Schema getClassSchema()
-
getEncoder
static BinaryMessageEncoder<TokenFullSyncState> getEncoder()
Return the BinaryMessageEncoder instance used by this class.
-
getDecoder
static BinaryMessageDecoder<TokenFullSyncState> getDecoder()
Return the BinaryMessageDecoder instance used by this class.
-
createDecoder
static BinaryMessageDecoder<TokenFullSyncState> createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
- Parameters:
resolver
- a SchemaStore used to find schemas by fingerprint
-
toByteBuffer
ByteBuffer toByteBuffer()
Serializes this TokenFullSyncState to a ByteBuffer.
-
fromByteBuffer
static TokenFullSyncState fromByteBuffer(ByteBuffer b)
Deserializes a TokenFullSyncState from a ByteBuffer.
- Parameters:
b
- a byte buffer holding serialized data for an instance of this class
-
getSpecificData
SpecificData getSpecificData()
-
getSchema
Schema getSchema()
-
getConversion
Conversion<out Object> getConversion(int field)
-
newBuilder
static TokenFullSyncState.Builder newBuilder()
Creates a new TokenFullSyncState RecordBuilder.
-
newBuilder
static TokenFullSyncState.Builder newBuilder(TokenFullSyncState.Builder other)
Creates a new TokenFullSyncState RecordBuilder by copying an existing Builder.
- Parameters:
other
- The existing builder to copy.
-
newBuilder
static TokenFullSyncState.Builder newBuilder(TokenFullSyncState other)
Creates a new TokenFullSyncState RecordBuilder by copying an existing TokenFullSyncState instance.
- Parameters:
other
- The existing instance to copy.
-
writeExternal
void writeExternal(ObjectOutput out)
-
readExternal
void readExternal(ObjectInput in)
-
-
-
-