StateForCheckpointWithPartitionId
data class StateForCheckpointWithPartitionId(val pendingState: OpaqueStateValue, val partitionId: String?, val pendingNumRecords: Long, var id: Int?)
Constructors
Link copied to clipboard
constructor(pendingState: OpaqueStateValue, partitionId: String?, pendingNumRecords: Long, id: Int?)