Package org.apache.cassandra.service.reads.thresholds

Class WarningsSnapshot

java.lang.Object

org.apache.cassandra.service.reads.thresholds.WarningsSnapshot

public class WarningsSnapshot
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WarningsSnapshot.Builder
static class	WarningsSnapshot.Counter
static class	WarningsSnapshot.Warnings

Field Summary

Fields

Modifier and Type	Field	Description
WarningsSnapshot.Warnings	localReadSize
WarningsSnapshot.Warnings	rowIndexReadSize
WarningsSnapshot.Warnings	tombstones

Method Summary

Modifier and Type	Method	Description
static WarningsSnapshot	create(WarningsSnapshot.Warnings tombstones, WarningsSnapshot.Warnings localReadSize, WarningsSnapshot.Warnings rowIndexTooLarge)
static WarningsSnapshot	empty()
boolean	equals(java.lang.Object o)
int	hashCode()
boolean	isDefined()
boolean	isEmpty()
static java.lang.String	localReadSizeAbortMessage(long nodes, long bytes, java.lang.String cql)
static java.lang.String	localReadSizeWarnMessage(int nodes, long bytes, java.lang.String cql)
void	maybeAbort(ReadCommand command, ConsistencyLevel cl, int received, int blockFor, boolean isDataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
static WarningsSnapshot	merge(WarningsSnapshot... values)
static java.lang.String	rowIndexReadSizeAbortMessage(long nodes, long bytes, java.lang.String cql)
static java.lang.String	rowIndexSizeWarnMessage(int nodes, long bytes, java.lang.String cql)
static java.lang.String	tombstoneAbortMessage(int nodes, long tombstones, java.lang.String cql)
static java.lang.String	tombstoneWarnMessage(int nodes, long tombstones, java.lang.String cql)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

tombstones

public final WarningsSnapshot.Warnings tombstones

localReadSize

public final WarningsSnapshot.Warnings localReadSize

rowIndexReadSize

public final WarningsSnapshot.Warnings rowIndexReadSize

Method Detail

empty

public static WarningsSnapshot empty()

create

public static WarningsSnapshot create(WarningsSnapshot.Warnings tombstones,
                                      WarningsSnapshot.Warnings localReadSize,
                                      WarningsSnapshot.Warnings rowIndexTooLarge)

merge

public static WarningsSnapshot merge(WarningsSnapshot... values)

isEmpty

public boolean isEmpty()

isDefined

public boolean isDefined()

maybeAbort

public void maybeAbort(ReadCommand command,
                       ConsistencyLevel cl,
                       int received,
                       int blockFor,
                       boolean isDataPresent,
                       java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)

tombstoneAbortMessage

public static java.lang.String tombstoneAbortMessage(int nodes,
                                                     long tombstones,
                                                     java.lang.String cql)

tombstoneWarnMessage

public static java.lang.String tombstoneWarnMessage(int nodes,
                                                    long tombstones,
                                                    java.lang.String cql)

localReadSizeAbortMessage

public static java.lang.String localReadSizeAbortMessage(long nodes,
                                                         long bytes,
                                                         java.lang.String cql)

localReadSizeWarnMessage

public static java.lang.String localReadSizeWarnMessage(int nodes,
                                                        long bytes,
                                                        java.lang.String cql)

rowIndexReadSizeAbortMessage

public static java.lang.String rowIndexReadSizeAbortMessage(long nodes,
                                                            long bytes,
                                                            java.lang.String cql)

rowIndexSizeWarnMessage

public static java.lang.String rowIndexSizeWarnMessage(int nodes,
                                                       long bytes,
                                                       java.lang.String cql)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object