Uses of Class
org.apache.cassandra.transport.Dispatcher.RequestTime

Packages that use Dispatcher.RequestTime

Package	Description
org.apache.cassandra.cql3
org.apache.cassandra.cql3.statements
org.apache.cassandra.cql3.statements.schema
org.apache.cassandra.db
org.apache.cassandra.locator
org.apache.cassandra.net
org.apache.cassandra.service
org.apache.cassandra.service.pager
org.apache.cassandra.service.paxos
org.apache.cassandra.service.paxos.v1
org.apache.cassandra.service.reads
org.apache.cassandra.service.reads.range
org.apache.cassandra.service.reads.repair
org.apache.cassandra.transport
org.apache.cassandra.transport.messages

Uses of Dispatcher.RequestTime in org.apache.cassandra.cql3

Methods in org.apache.cassandra.cql3 with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
ResultMessage	CQLStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)	Execute the statement and return the resulting result or null if there is no result.
static UntypedResultSet	QueryProcessor.executeInternalWithNow(long nowInSec, Dispatcher.RequestTime requestTime, String query, Object... values)	A special version of executeLocally that takes the time used as "now" for the query in argument.
ResultMessage	CustomPayloadMirroringQueryHandler.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryHandler.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
static ResultMessage	QueryProcessor.process(String queryString, ConsistencyLevel cl, QueryState queryState, Dispatcher.RequestTime requestTime)
ResultMessage	QueryProcessor.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryProcessor.process(CQLStatement prepared, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	CustomPayloadMirroringQueryHandler.processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryHandler.processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryProcessor.processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryProcessor.processBatch(BatchStatement batch, QueryState queryState, BatchQueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	CustomPayloadMirroringQueryHandler.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryHandler.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryProcessor.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String,ByteBuffer> customPayload, Dispatcher.RequestTime requestTime)
ResultMessage	QueryProcessor.processPrepared(CQLStatement statement, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	QueryProcessor.processStatement(CQLStatement statement, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.cql3.statements

Methods in org.apache.cassandra.cql3.statements with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
ResultMessage	AuthenticationStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	AuthorizationStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	BatchStatement.execute(QueryState queryState, BatchQueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	BatchStatement.execute(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime)
final ResultMessage	DescribeStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	ModificationStatement.execute(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage.Rows	SelectStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	TruncateStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage	UseStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)
ResultMessage.Rows	SelectStatement.executeInternal(QueryState state, QueryOptions options, long nowInSec, Dispatcher.RequestTime requestTime)
ResultMessage	ModificationStatement.executeInternalWithoutCondition(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime)
List<? extends IMutation>	BatchStatement.getMutations(ClientState state, BatchQueryOptions options, boolean local, long batchTimestamp, long nowInSeconds, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.cql3.statements.schema

Methods in org.apache.cassandra.cql3.statements.schema with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
ResultMessage	AlterSchemaStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.db

Methods in org.apache.cassandra.db with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
Message<ReadCommand>	ReadCommand.createMessage(boolean trackRepairedData, Dispatcher.RequestTime requestTime)	Creates a message for this command.
PartitionIterator	PartitionRangeReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	PartitionRangeReadCommand.VirtualTablePartitionRangeReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	ReadQuery.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)	Executes the query at the provided consistency level.
PartitionIterator	SinglePartitionReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	SinglePartitionReadCommand.Group.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	SinglePartitionReadCommand.VirtualTableGroup.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)
PartitionIterator	SinglePartitionReadCommand.VirtualTableSinglePartitionReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.locator

Methods in org.apache.cassandra.locator with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
<T> AbstractWriteResponseHandler<T>	AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
<T> AbstractWriteResponseHandler<T>	AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime, ConsistencyLevel idealConsistencyLevel)

Uses of Dispatcher.RequestTime in org.apache.cassandra.net

Methods in org.apache.cassandra.net with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
static <T> Message<T>	Message.outWithFlags(Verb verb, T payload, Dispatcher.RequestTime requestTime, List<MessageFlag> flags)

Uses of Dispatcher.RequestTime in org.apache.cassandra.service

Methods in org.apache.cassandra.service that return Dispatcher.RequestTime

Modifier and Type	Method	Description
Dispatcher.RequestTime	AbstractWriteResponseHandler.getRequestTime()

Methods in org.apache.cassandra.service with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
void	StorageProxy.WritePerformer.apply(IMutation mutation, ReplicaPlan.ForWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, String localDataCenter, Dispatcher.RequestTime requestTime)
static AbstractWriteResponseHandler<IMutation>	StorageProxy.applyCounterMutationOnCoordinator(CounterMutation cm, String localDataCenter, Dispatcher.RequestTime requestTime)
static AbstractWriteResponseHandler<IMutation>	StorageProxy.applyCounterMutationOnLeader(CounterMutation cm, String localDataCenter, Runnable callback, Dispatcher.RequestTime requestTime)
static RowIterator	StorageProxy.cas(String keyspaceName, String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, long nowInSeconds, Dispatcher.RequestTime requestTime)	Apply @param updates if and only if the current values in the row for @param key match the provided @param conditions.
static PartitionIterator	StorageProxy.getRangeSlice(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)
static RowIterator	StorageProxy.legacyCas(String keyspaceName, String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, long nowInSeconds, Dispatcher.RequestTime requestTime)
static void	StorageProxy.mutate(List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)	Use this method to have these Mutations applied across all replicas.
static void	StorageProxy.mutateAtomically(Collection<Mutation> mutations, ConsistencyLevel consistency_level, boolean requireQuorumForRemove, Dispatcher.RequestTime requestTime)	See mutate.
static AbstractWriteResponseHandler<IMutation>	StorageProxy.mutateCounter(CounterMutation cm, String localDataCenter, Dispatcher.RequestTime requestTime)	Handle counter mutation on the coordinator host.
static void	StorageProxy.mutateMV(ByteBuffer dataKey, Collection<Mutation> mutations, boolean writeCommitLog, AtomicLong baseComplete, Dispatcher.RequestTime requestTime)	Use this method to have these Mutations applied across all replicas.
static void	StorageProxy.mutateWithTriggers(List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, boolean mutateAtomically, Dispatcher.RequestTime requestTime)
static AbstractWriteResponseHandler<IMutation>	StorageProxy.performWrite(IMutation mutation, ConsistencyLevel consistencyLevel, String localDataCenter, StorageProxy.WritePerformer performer, Runnable callback, WriteType writeType, Dispatcher.RequestTime requestTime)	Perform the write of a mutation given a WritePerformer.
static PartitionIterator	StorageProxy.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)	Performs the actual reading of a row out of the StorageService, fetching a specific set of column names from a given column family.
static RowIterator	StorageProxy.readOne(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)
static void	StorageProxy.sendToHintedReplicas(Mutation mutation, ReplicaPlan.ForWrite plan, AbstractWriteResponseHandler<IMutation> responseHandler, String localDataCenter, Stage stage, Dispatcher.RequestTime requestTime)	Send the mutations to the right targets, write it locally if it corresponds or writes a hint when the node is not available.

Constructors in org.apache.cassandra.service with parameters of type Dispatcher.RequestTime

Modifier	Constructor	Description
protected	AbstractWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	BatchlogResponseHandler(AbstractWriteResponseHandler<T> wrapped, int requiredBeforeFinish, BatchlogResponseHandler.BatchlogCleanup cleanup, Dispatcher.RequestTime requestTime)
	DatacenterSyncWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	DatacenterWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	LocalReadRunnable(ReadCommand command, ReadCallback handler, Dispatcher.RequestTime requestTime)
	LocalReadRunnable(ReadCommand command, ReadCallback handler, Dispatcher.RequestTime requestTime, boolean trackRepairedStatus)
	WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.service.pager

Methods in org.apache.cassandra.service.pager with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
PartitionIterator	AggregationQueryPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)
PartitionIterator	MultiPartitionPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)
PartitionIterator	QueryPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)	Fetches the next page.

Constructors in org.apache.cassandra.service.pager with parameters of type Dispatcher.RequestTime

Modifier	Constructor	Description
	AggregationPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)
	AggregationPartitionIterator(int pageSize, ReadExecutionController executionController, Dispatcher.RequestTime requestTime)
	GroupByPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)
	GroupByPartitionIterator(int pageSize, ReadExecutionController executionController, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.service.paxos

Methods in org.apache.cassandra.service.paxos with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
static PartitionIterator	Paxos.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyForConsensus, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.service.paxos.v1

Constructors in org.apache.cassandra.service.paxos.v1 with parameters of type Dispatcher.RequestTime

Modifier	Constructor	Description
	AbstractPaxosCallback(int targets, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime)
	PrepareCallback(DecoratedKey key, TableMetadata metadata, int targets, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime)
	ProposeCallback(int totalTargets, int requiredTargets, boolean failFast, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.service.reads

Fields in org.apache.cassandra.service.reads declared as Dispatcher.RequestTime

Modifier and Type	Field	Description
protected final Dispatcher.RequestTime	AbstractReadExecutor.requestTime
protected final Dispatcher.RequestTime	ResponseResolver.requestTime

Methods in org.apache.cassandra.service.reads with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
static UnfilteredPartitionIterator	ShortReadProtection.extend(Replica source, Runnable preFetchCallback, UnfilteredPartitionIterator partitions, ReadCommand command, DataLimits.Counter mergedResultCounter, Dispatcher.RequestTime requestTime, boolean enforceStrictLiveness)
static AbstractReadExecutor	AbstractReadExecutor.getReadExecutor(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)

Constructors in org.apache.cassandra.service.reads with parameters of type Dispatcher.RequestTime

Modifier	Constructor	Description
	DataResolver(ReadCommand command, Supplier<? extends P> replicaPlan, ReadRepair<E,P> readRepair, Dispatcher.RequestTime requestTime)
	DataResolver(ReadCommand command, Supplier<? extends P> replicaPlan, ReadRepair<E,P> readRepair, Dispatcher.RequestTime requestTime, boolean trackRepairedStatus)
	DigestResolver(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
	NeverSpeculatingReadExecutor(ColumnFamilyStore cfs, ReadCommand command, ReplicaPlan.ForTokenRead replicaPlan, Dispatcher.RequestTime requestTime, boolean logFailedSpeculation)
	ReadCallback(ResponseResolver<E,P> resolver, ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
	ResponseResolver(ReadCommand command, Supplier<? extends P> replicaPlan, Dispatcher.RequestTime requestTime)
	ShortReadPartitionsProtection(ReadCommand command, Replica source, Runnable preFetchCallback, DataLimits.Counter singleResultCounter, DataLimits.Counter mergedResultCounter, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.service.reads.range

Methods in org.apache.cassandra.service.reads.range with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
static PartitionIterator	RangeCommands.partitions(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.service.reads.repair

Fields in org.apache.cassandra.service.reads.repair declared as Dispatcher.RequestTime

Modifier and Type	Field	Description
protected final Dispatcher.RequestTime	AbstractReadRepair.requestTime

Methods in org.apache.cassandra.service.reads.repair with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
static <E extends Endpoints<E>, P extends ReplicaPlan.ForRead<E, P>> ReadRepair<E,P>	ReadRepair.create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
<E extends Endpoints<E>, P extends ReplicaPlan.ForRead<E, P>> ReadRepair<E,P>	ReadRepair.Factory.create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)

Constructors in org.apache.cassandra.service.reads.repair with parameters of type Dispatcher.RequestTime

Modifier	Constructor	Description
	AbstractReadRepair(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)

Uses of Dispatcher.RequestTime in org.apache.cassandra.transport

Methods in org.apache.cassandra.transport that return Dispatcher.RequestTime

Modifier and Type	Method	Description
static Dispatcher.RequestTime	Dispatcher.RequestTime.forImmediateExecution()

Methods in org.apache.cassandra.transport with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
final Message.Response	Message.Request.execute(QueryState queryState, Dispatcher.RequestTime requestTime)
protected abstract Message.Response	Message.Request.execute(QueryState queryState, Dispatcher.RequestTime requestTime, boolean traceRequest)

Uses of Dispatcher.RequestTime in org.apache.cassandra.transport.messages

Methods in org.apache.cassandra.transport.messages with parameters of type Dispatcher.RequestTime

Modifier and Type	Method	Description
protected Message.Response	AuthResponse.execute(QueryState queryState, Dispatcher.RequestTime requestTime, boolean traceRequest)
protected Message.Response	BatchMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)
protected Message.Response	ExecuteMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)
protected Message.Response	OptionsMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)
protected Message.Response	PrepareMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)
protected Message.Response	QueryMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)
protected Message.Response	RegisterMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)
protected Message.Response	StartupMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)