Package org.apache.pinot.common.response
Interface BrokerResponse
-
- All Known Implementing Classes:
BrokerResponseNative
public interface BrokerResponseInterface for broker response.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description intgetExceptionsSize()Get number of exceptions recorded in the response.longgetMinConsumingFreshnessTimeMs()Get the minimum freshness timestamp across consuming segments that were queriedlonggetNumConsumingSegmentsQueried()Get number of consuming segments that were queried.longgetNumDocsScanned()Get number of documents scanned while processing the query.longgetNumEntriesScannedInFilter()Get number of entries scanned in filter phase while processing the query.longgetNumEntriesScannedPostFilter()Get number of entries scanned post filter phase while processing the query.intgetNumRowsResultSet()Get the total number of rows in result setlonggetNumSegmentsMatched()Get number of segments that had at least one matching documentlonggetNumSegmentsProcessed()Get the number of segments processed by server after server side pruninglonggetNumSegmentsQueried()Get the number of segments queried by the broker after broker side pruningintgetNumServersQueried()Returns the number of servers queried.intgetNumServersResponded()Returns the number of servers responded.longgetOfflineResponseSerializationCpuTimeNs()Get the response serialization cpu time used against offline table in request handling, from the broker response.longgetOfflineSystemActivitiesCpuTimeNs()Get the system activities cpu time used against offline table in request handling, from the broker response.longgetOfflineThreadCpuTimeNs()Get the thread cpu time used against offline table in request handling, from the broker response.longgetOfflineTotalCpuTimeNs()Get the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against offline table in request handling, from the broker response.List<QueryProcessingException>getProcessingExceptions()Get the list of exceptionslonggetRealtimeResponseSerializationCpuTimeNs()Get the response serialization cpu time used against realtime table in request handling, from the broker response.longgetRealtimeSystemActivitiesCpuTimeNs()Get the system activities cpu time used against realtime table in request handling, from the broker response.longgetRealtimeThreadCpuTimeNs()Get the thread cpu time used against realtime table in request handling, from the broker response.longgetRealtimeTotalCpuTimeNs()Get the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against realtime table in request handling, from the broker response.longgetTotalDocs()Get total number of documents within the table hit.booleanisNumGroupsLimitReached()Returns whether the number of groups limit has been reached.voidsetExceptions(List<ProcessingException> exceptions)Set exceptions caught during request handling, into the broker response.voidsetNumRowsResultSet(int numRowsResultSet)Set the total number of rows in result setvoidsetNumServersQueried(int numServersQueried)Set the number of servers got queried by the broker.voidsetNumServersResponded(int numServersResponded)Set the number of servers responded to the broker.voidsetOfflineResponseSerializationCpuTimeNs(long offlineResponseSerializationCpuTimeNs)Set the response serialization cpu time used against offline table in request handling, into the broker response.voidsetOfflineSystemActivitiesCpuTimeNs(long offlineSystemActivitiesCpuTimeNs)Set the system activities cpu time used against offline table in request handling, into the broker response.voidsetOfflineThreadCpuTimeNs(long offlineThreadCpuTimeNs)Set the total thread cpu time used against offline table in request handling, into the broker response.voidsetOfflineTotalCpuTimeNs(long offlineTotalCpuTimeNs)Set the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against offline table in request handling, into the broker response.voidsetRealtimeResponseSerializationCpuTimeNs(long realtimeResponseSerializationCpuTimeNs)Set the response serialization cpu time used against realtime table in request handling, into the broker response.voidsetRealtimeSystemActivitiesCpuTimeNs(long realtimeSystemActivitiesCpuTimeNs)Set the system activities cpu time used against realtime table in request handling, into the broker response.voidsetRealtimeThreadCpuTimeNs(long realtimeThreadCpuTimeNs)Set the total thread cpu time used against realtime table in request handling, into the broker response.voidsetRealtimeTotalCpuTimeNs(long realtimeTotalCpuTimeNs)Set the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against realtime table in request handling, into the broker response.voidsetTimeUsedMs(long timeUsedMs)Set the total time used in request handling, into the broker response.StringtoJsonString()Convert the broker response to JSON String.
-
-
-
Method Detail
-
setExceptions
void setExceptions(List<ProcessingException> exceptions)
Set exceptions caught during request handling, into the broker response.
-
setNumServersQueried
void setNumServersQueried(int numServersQueried)
Set the number of servers got queried by the broker.- Parameters:
numServersQueried- number of servers got queried.
-
setNumServersResponded
void setNumServersResponded(int numServersResponded)
Set the number of servers responded to the broker.- Parameters:
numServersResponded- number of servers responded.
-
setTimeUsedMs
void setTimeUsedMs(long timeUsedMs)
Set the total time used in request handling, into the broker response.
-
setNumRowsResultSet
void setNumRowsResultSet(int numRowsResultSet)
Set the total number of rows in result set
-
toJsonString
String toJsonString() throws Exception
Convert the broker response to JSON String.- Throws:
Exception
-
getNumServersQueried
int getNumServersQueried()
Returns the number of servers queried.
-
getNumServersResponded
int getNumServersResponded()
Returns the number of servers responded.
-
getNumDocsScanned
long getNumDocsScanned()
Get number of documents scanned while processing the query.
-
getNumEntriesScannedInFilter
long getNumEntriesScannedInFilter()
Get number of entries scanned in filter phase while processing the query.
-
getNumEntriesScannedPostFilter
long getNumEntriesScannedPostFilter()
Get number of entries scanned post filter phase while processing the query.
-
getNumSegmentsQueried
long getNumSegmentsQueried()
Get the number of segments queried by the broker after broker side pruning
-
getNumSegmentsProcessed
long getNumSegmentsProcessed()
Get the number of segments processed by server after server side pruning
-
getNumSegmentsMatched
long getNumSegmentsMatched()
Get number of segments that had at least one matching document
-
getNumConsumingSegmentsQueried
long getNumConsumingSegmentsQueried()
Get number of consuming segments that were queried.
-
getMinConsumingFreshnessTimeMs
long getMinConsumingFreshnessTimeMs()
Get the minimum freshness timestamp across consuming segments that were queried
-
getTotalDocs
long getTotalDocs()
Get total number of documents within the table hit.
-
isNumGroupsLimitReached
boolean isNumGroupsLimitReached()
Returns whether the number of groups limit has been reached.
-
getExceptionsSize
int getExceptionsSize()
Get number of exceptions recorded in the response.
-
getProcessingExceptions
List<QueryProcessingException> getProcessingExceptions()
Get the list of exceptions
-
getNumRowsResultSet
int getNumRowsResultSet()
Get the total number of rows in result set
-
setOfflineThreadCpuTimeNs
void setOfflineThreadCpuTimeNs(long offlineThreadCpuTimeNs)
Set the total thread cpu time used against offline table in request handling, into the broker response.
-
getOfflineThreadCpuTimeNs
long getOfflineThreadCpuTimeNs()
Get the thread cpu time used against offline table in request handling, from the broker response.
-
getRealtimeThreadCpuTimeNs
long getRealtimeThreadCpuTimeNs()
Get the thread cpu time used against realtime table in request handling, from the broker response.
-
setRealtimeThreadCpuTimeNs
void setRealtimeThreadCpuTimeNs(long realtimeThreadCpuTimeNs)
Set the total thread cpu time used against realtime table in request handling, into the broker response.
-
getOfflineSystemActivitiesCpuTimeNs
long getOfflineSystemActivitiesCpuTimeNs()
Get the system activities cpu time used against offline table in request handling, from the broker response.
-
setOfflineSystemActivitiesCpuTimeNs
void setOfflineSystemActivitiesCpuTimeNs(long offlineSystemActivitiesCpuTimeNs)
Set the system activities cpu time used against offline table in request handling, into the broker response.
-
getRealtimeSystemActivitiesCpuTimeNs
long getRealtimeSystemActivitiesCpuTimeNs()
Get the system activities cpu time used against realtime table in request handling, from the broker response.
-
setRealtimeSystemActivitiesCpuTimeNs
void setRealtimeSystemActivitiesCpuTimeNs(long realtimeSystemActivitiesCpuTimeNs)
Set the system activities cpu time used against realtime table in request handling, into the broker response.
-
getOfflineResponseSerializationCpuTimeNs
long getOfflineResponseSerializationCpuTimeNs()
Get the response serialization cpu time used against offline table in request handling, from the broker response.
-
setOfflineResponseSerializationCpuTimeNs
void setOfflineResponseSerializationCpuTimeNs(long offlineResponseSerializationCpuTimeNs)
Set the response serialization cpu time used against offline table in request handling, into the broker response.
-
getRealtimeResponseSerializationCpuTimeNs
long getRealtimeResponseSerializationCpuTimeNs()
Get the response serialization cpu time used against realtime table in request handling, from the broker response.
-
setRealtimeResponseSerializationCpuTimeNs
void setRealtimeResponseSerializationCpuTimeNs(long realtimeResponseSerializationCpuTimeNs)
Set the response serialization cpu time used against realtime table in request handling, into the broker response.
-
getOfflineTotalCpuTimeNs
long getOfflineTotalCpuTimeNs()
Get the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against offline table in request handling, from the broker response.
-
setOfflineTotalCpuTimeNs
void setOfflineTotalCpuTimeNs(long offlineTotalCpuTimeNs)
Set the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against offline table in request handling, into the broker response.
-
getRealtimeTotalCpuTimeNs
long getRealtimeTotalCpuTimeNs()
Get the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against realtime table in request handling, from the broker response.
-
setRealtimeTotalCpuTimeNs
void setRealtimeTotalCpuTimeNs(long realtimeTotalCpuTimeNs)
Set the total cpu time(thread cpu time + system activities cpu time + response serialization cpu time) used against realtime table in request handling, into the broker response.
-
-