Uses of Class
org.apache.cassandra.service.paxos.Ballot
-
-
Uses of Ballot in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type Ballot Modifier and Type Method Description PartitionUpdateCQL3CasRequest. makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot) -
Uses of Ballot in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return Ballot Modifier and Type Method Description BallotColumnFamilyStore. getPaxosRepairLowBound(DecoratedKey key)Methods in org.apache.cassandra.db with parameters of type Ballot Modifier and Type Method Description voidColumnFamilyStore. onPaxosRepairComplete(java.util.Collection<Range<Token>> ranges, Ballot highBallot)static voidSystemKeyspace. savePaxosReadPromise(DecoratedKey key, TableMetadata metadata, Ballot ballot)static voidSystemKeyspace. savePaxosWritePromise(DecoratedKey key, TableMetadata metadata, Ballot ballot) -
Uses of Ballot in org.apache.cassandra.db.marshal
Methods in org.apache.cassandra.db.marshal that return Ballot Modifier and Type Method Description BallotByteArrayAccessor. toBallot(byte[] value)BallotByteBufferAccessor. toBallot(java.nio.ByteBuffer value)BallotValueAccessor. toBallot(V value)returns a TimeUUID from offset 0 -
Uses of Ballot in org.apache.cassandra.service
Methods in org.apache.cassandra.service with parameters of type Ballot Modifier and Type Method Description PartitionUpdateCASRequest. makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot)The updates to perform of a CAS success. -
Uses of Ballot in org.apache.cassandra.service.paxos
Fields in org.apache.cassandra.service.paxos declared as Ballot Modifier and Type Field Description BallotCommit. ballotBallotPaxosState.Snapshot. promisedBallotPaxosState.Snapshot. promisedWriteMethods in org.apache.cassandra.service.paxos that return Ballot Modifier and Type Method Description BallotPaxosState. acceptIfLatest(Commit.Proposal proposal)Record an acceptance of the proposal if there is no newer promise; otherwise inform the caller of the newer ballotBallotBallotGenerator. atUnixMicros(long unixMicros, Ballot.Flag flag)BallotBallotGenerator.Default. atUnixMicros(long unixMicros, Ballot.Flag flag)static BallotBallotGenerator.Global. atUnixMicros(long unixMicros, Ballot.Flag flag)static BallotBallot. atUnixMicrosWithLsb(long unixMicros, long uniqueLsb, Ballot.Flag flag)static BallotPaxos. ballotForConsistency(long whenInMicros, ConsistencyLevel consistency)Create a ballot uuid with the consistency level encoded in the timestamp.BallotPaxosRepairHistory. ballotForToken(Token token)BallotPaxosRepairHistory.Searcher. ballotForToken(Token token)static BallotBallot. deserialize(byte[] bytes)static BallotBallot. deserialize(java.nio.ByteBuffer buffer)static BallotBallot. deserialize(DataInputPlus in)BallotBallot.Serializer. deserialize(DataInputPlus in, int version)<V> BallotBallot.Serializer. deserialize(V value, ValueAccessor<V> accessor)static BallotBallot. fromBytes(long msb, long lsb)static BallotBallot. fromString(java.lang.String uuidString)static BallotBallot. fromUuid(java.util.UUID uuid)BallotTablePaxosRepairHistory. getBallotForToken(Token token)BallotAbstractPaxosRepair. incompleteBallot()static BallotCommit. latest(Ballot a, Ballot b)the latest of two ballots, or the first ballot if equal timestampsstatic BallotCommit. latest(Commit a, Ballot b)the latest of two ballots, or the first ballot if equal timestampsBallotPaxosState.Snapshot. latestWitnessedOrLowBound()BallotPaxosState.Snapshot. latestWitnessedOrLowBound(Ballot latestWriteOrLowBound)BallotPaxosState.Snapshot. latestWriteOrLowBound()BallotPaxosRepairHistory. maxLowBound()static BallotPaxos. newBallot(Ballot minimumBallot, ConsistencyLevel consistency)BallotBallotGenerator.Default. next(long minUnixMicros, Ballot.Flag flag)BallotBallotGenerator. next(long minUnixMicros, Ballot.Flag flag)static BallotBallotGenerator.Global. nextBallot(long minUnixMicros, Ballot.Flag flag)static BallotBallotGenerator.Global. nextBallot(Ballot.Flag flag)static BallotBallot. none()BallotBallotGenerator.Default. stale(long fromInMicros, long toInMicros, Ballot.Flag flag)BallotBallotGenerator. stale(long fromUnixMicros, long toUnixMicros, Ballot.Flag flag)static BallotBallotGenerator.Global. staleBallot(long fromUnixMicros, long toUnixMicros, Ballot.Flag flag)BallotPaxosState.MaybePromise. supersededBy()Methods in org.apache.cassandra.service.paxos that return types with arguments of type Ballot Modifier and Type Method Description java.lang.Class<Ballot>Ballot.Serializer. getType()Methods in org.apache.cassandra.service.paxos with parameters of type Ballot Modifier and Type Method Description static PaxosRepairHistoryPaxosRepairHistory. add(PaxosRepairHistory existing, java.util.Collection<Range<Token>> ranges, Ballot ballot)voidTablePaxosRepairHistory. add(java.util.Collection<Range<Token>> ranges, Ballot ballot, boolean flush)static ConsistencyLevelPaxos. consistency(Ballot ballot)static PaxosRepairPaxosRepair. create(ConsistencyLevel consistency, DecoratedKey partitionKey, Ballot incompleteBallot, TableMetadata table)static Commit.ProposalCommit.Proposal. empty(Ballot ballot, DecoratedKey partitionKey, TableMetadata metadata)booleanCommit. hasBallot(Ballot ballot)booleanCommit. isAfter(Ballot otherBallot)static booleanCommit. isAfter(Ballot testIsAfter, Ballot testIsBefore)static booleanCommit. isAfter(Ballot testIsAfter, Commit testIsBefore)static booleanCommit. isAfter(Commit testIsAfter, Ballot testIsBefore)booleanCommit. isBefore(Ballot otherBallot)booleanCommit. isSameOrAfter(Ballot otherBallot)static BallotCommit. latest(Ballot a, Ballot b)the latest of two ballots, or the first ballot if equal timestampsstatic BallotCommit. latest(Commit a, Ballot b)the latest of two ballots, or the first ballot if equal timestampsBallotPaxosState.Snapshot. latestWitnessedOrLowBound(Ballot latestWriteOrLowBound)static BallotPaxos. newBallot(Ballot minimumBallot, ConsistencyLevel consistency)static CommitCommit. newPrepare(DecoratedKey partitionKey, TableMetadata metadata, Ballot ballot)static CommitCommit. newProposal(Ballot ballot, PartitionUpdate update)Deprecated.static Commit.ProposalCommit.Proposal. of(Ballot ballot, PartitionUpdate update)voidPaxosPrepare. onRefreshSuccess(Ballot isSupersededBy, InetAddressAndPort from)PaxosState.MaybePromisePaxosState. promiseIfNewer(Ballot ballot, boolean isWrite)Record the requested ballot as promised if it is newer than our current promise; otherwise do nothing.voidBallot.Serializer. serialize(Ballot t, DataOutputPlus out, int version)longBallot.Serializer. serializedSize(Ballot t, int version)static booleanCommit. timestampsClash(Ballot a, Ballot b)static booleanCommit. timestampsClash(Commit a, Ballot b)unequal ballots with same timestampConstructors in org.apache.cassandra.service.paxos with parameters of type Ballot Constructor Description AbstractPaxosRepair(DecoratedKey partitionKey, Ballot incompleteBallot)Accepted(Ballot ballot, PartitionUpdate update)AcceptedWithTTL(Ballot ballot, PartitionUpdate update, int localDeletionTime)Agreed(Ballot ballot, PartitionUpdate update)Commit(Ballot ballot, PartitionUpdate update)Committed(Ballot ballot, PartitionUpdate update)CommittedWithTTL(Ballot ballot, PartitionUpdate update, int localDeletionTime)PaxosPrepareRefresh(Ballot prepared, org.apache.cassandra.service.paxos.Paxos.Participants participants, Commit.Committed latestCommitted, org.apache.cassandra.service.paxos.PaxosPrepareRefresh.Callbacks callbacks)Proposal(Ballot ballot, PartitionUpdate update)Snapshot(Ballot promised, Ballot promisedWrite, Commit.Accepted accepted, Commit.Committed committed)Constructor parameters in org.apache.cassandra.service.paxos with type arguments of type Ballot Constructor Description CommitSerializer(java.util.function.BiFunction<Ballot,PartitionUpdate,T> constructor) -
Uses of Ballot in org.apache.cassandra.service.paxos.cleanup
Constructors in org.apache.cassandra.service.paxos.cleanup with parameters of type Ballot Constructor Description PaxosCleanupHistory(TableId tableId, Ballot highBound, PaxosRepairHistory history) -
Uses of Ballot in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted that return Ballot Modifier and Type Method Description BallotPaxosKeyState. ballot()BallotUncommittedPaxosKey. ballot()static BallotPaxosRows. getHighBallot(Row row, Ballot current)BallotPaxosBallotTracker. getHighBound()BallotPaxosBallotTracker. getLowBound()static BallotPaxosRows. getPromise(Row row)static BallotPaxosRows. getWritePromise(Row row)Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type Ballot Modifier and Type Method Description static BallotPaxosRows. getHighBallot(Row row, Ballot current)static booleanPaxosRows. hasBallotBeforeOrEqualTo(Row row, Ballot ballot)voidPaxosBallotTracker. updateLowBound(Ballot update)Constructors in org.apache.cassandra.service.paxos.uncommitted with parameters of type Ballot Constructor Description PaxosKeyState(TableId tableId, DecoratedKey key, Ballot ballot, boolean committed)
-