Skip to content

Commit

Permalink
Add runtime stats for materialized view status
Browse files Browse the repository at this point in the history
Adding runtime stats for measuring the performance of the
getMaterializedViewStatus method.
  • Loading branch information
jainxrohit authored and highker committed Mar 31, 2022
1 parent 3fbbb67 commit 4b568c1
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ private RuntimeMetricName()
public static final String FRAGMENT_RESULT_CACHE_MISS = "fragmentResultCacheMissCount";
public static final String GET_VIEW_TIME_NANOS = "getViewTimeNanos";
public static final String GET_MATERIALIZED_VIEW_TIME_NANOS = "getMaterializedViewTimeNanos";
public static final String GET_MATERIALIZED_VIEW_STATUS_TIME_NANOS = "getMaterializedViewStatusTimeNanos";
public static final String GET_TABLE_HANDLE_TIME_NANOS = "getTableHandleTimeNanos";
public static final String GET_TABLE_METADATA_TIME_NANOS = "getTableMetadataTimeNanos";
public static final String GET_SPLITS_TIME_NANOS = "getSplitsTimeNanos";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -100,6 +100,7 @@
import static com.facebook.airlift.concurrent.MoreFutures.toListenableFuture;
import static com.facebook.presto.SystemSessionProperties.isIgnoreStatsCalculatorFailures;
import static com.facebook.presto.common.RuntimeMetricName.GET_LAYOUT_TIME_NANOS;
import static com.facebook.presto.common.RuntimeMetricName.GET_MATERIALIZED_VIEW_STATUS_TIME_NANOS;
import static com.facebook.presto.common.function.OperatorType.BETWEEN;
import static com.facebook.presto.common.function.OperatorType.EQUAL;
import static com.facebook.presto.common.function.OperatorType.GREATER_THAN;
Expand Down Expand Up @@ -1089,7 +1090,10 @@ public MaterializedViewStatus getMaterializedViewStatus(Session session, Qualifi

ConnectorId connectorId = materializedViewHandle.get().getConnectorId();
ConnectorMetadata metadata = getMetadata(session, connectorId);
return metadata.getMaterializedViewStatus(session.toConnectorSession(connectorId), toSchemaTableName(materializedViewName));

return session.getRuntimeStats().profileNanos(
GET_MATERIALIZED_VIEW_STATUS_TIME_NANOS,
() -> metadata.getMaterializedViewStatus(session.toConnectorSession(connectorId), toSchemaTableName(materializedViewName)));
}

@Override
Expand Down

0 comments on commit 4b568c1

Please sign in to comment.