Uses of Class
org.apache.cassandra.service.paxos.Ballot
Packages that use Ballot
Package
Description
-
Uses of Ballot in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type BallotModifier and TypeMethodDescriptionCQL3CasRequest.makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot) -
Uses of Ballot in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return BallotMethods in org.apache.cassandra.db with parameters of type BallotModifier and TypeMethodDescriptionvoidColumnFamilyStore.onPaxosRepairComplete(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 -
Uses of Ballot in org.apache.cassandra.service
Methods in org.apache.cassandra.service with parameters of type BallotModifier and TypeMethodDescriptionCASRequest.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 BallotModifier and TypeFieldDescriptionfinal BallotCommit.ballotfinal BallotPaxosState.Snapshot.promisedfinal BallotPaxosState.Snapshot.promisedWriteMethods in org.apache.cassandra.service.paxos that return BallotModifier and TypeMethodDescriptionPaxosState.acceptIfLatest(Commit.Proposal proposal) Record an acceptance of the proposal if there is no newer promise; otherwise inform the caller of the newer ballotBallotGenerator.atUnixMicros(long unixMicros, Ballot.Flag flag) BallotGenerator.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.PaxosRepairHistory.ballotForToken(Token token) PaxosRepairHistory.Searcher.ballotForToken(Token token) static BallotBallot.deserialize(byte[] bytes) static BallotBallot.deserialize(ByteBuffer buffer) static BallotBallot.deserialize(DataInputPlus in) Ballot.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(String uuidString) static BallotTablePaxosRepairHistory.getBallotForToken(Token token) AbstractPaxosRepair.incompleteBallot()static Ballotthe latest of two ballots, or the first ballot if equal timestampsstatic Ballotthe latest of two ballots, or the first ballot if equal timestampsPaxosState.Snapshot.latestWitnessedOrLowBound()PaxosState.Snapshot.latestWitnessedOrLowBound(Ballot latestWriteOrLowBound) PaxosState.Snapshot.latestWriteOrLowBound()PaxosRepairHistory.maxLowBound()static BallotPaxos.newBallot(Ballot minimumBallot, ConsistencyLevel consistency) BallotGenerator.Default.next(long minUnixMicros, Ballot.Flag flag) BallotGenerator.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()BallotGenerator.Default.stale(long fromInMicros, long toInMicros, Ballot.Flag flag) BallotGenerator.stale(long fromUnixMicros, long toUnixMicros, Ballot.Flag flag) static BallotBallotGenerator.Global.staleBallot(long fromUnixMicros, long toUnixMicros, Ballot.Flag flag) PaxosState.MaybePromise.supersededBy()Methods in org.apache.cassandra.service.paxos that return types with arguments of type BallotMethods in org.apache.cassandra.service.paxos with parameters of type BallotModifier and TypeMethodDescriptionstatic PaxosRepairHistoryPaxosRepairHistory.add(PaxosRepairHistory existing, Collection<Range<Token>> ranges, Ballot ballot) voidTablePaxosRepairHistory.add(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) booleanbooleanstatic booleanstatic booleanstatic booleanbooleanbooleanCommit.isSameOrAfter(Ballot otherBallot) static Ballotthe latest of two ballots, or the first ballot if equal timestampsstatic Ballotthe latest of two ballots, or the first ballot if equal timestampsPaxosState.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.See CASSANDRA-17164static Commit.ProposalCommit.Proposal.of(Ballot ballot, PartitionUpdate update) voidPaxosPrepare.onRefreshSuccess(Ballot isSupersededBy, InetAddressAndPort from) PaxosState.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 BallotModifierConstructorDescriptionAbstractPaxosRepair(DecoratedKey partitionKey, Ballot incompleteBallot) Accepted(Ballot ballot, PartitionUpdate update) AcceptedWithTTL(Ballot ballot, PartitionUpdate update, long localDeletionTime) Agreed(Ballot ballot, PartitionUpdate update) Commit(Ballot ballot, PartitionUpdate update) Committed(Ballot ballot, PartitionUpdate update) CommittedWithTTL(Ballot ballot, PartitionUpdate update, long 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 -
Uses of Ballot in org.apache.cassandra.service.paxos.cleanup
Constructors in org.apache.cassandra.service.paxos.cleanup with parameters of type BallotModifierConstructorDescriptionPaxosCleanupHistory(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 BallotModifier and TypeMethodDescriptionPaxosKeyState.ballot()UncommittedPaxosKey.ballot()static BallotPaxosRows.getHighBallot(Row row, Ballot current) PaxosBallotTracker.getHighBound()PaxosBallotTracker.getLowBound()static BallotPaxosRows.getPromise(Row row) static BallotPaxosRows.getWritePromise(Row row) Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type BallotModifier and TypeMethodDescriptionstatic 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 BallotModifierConstructorDescriptionPaxosKeyState(TableId tableId, DecoratedKey key, Ballot ballot, boolean committed)