@Override
    public void provideMetrics(Node node, MetricsCollectionContext context) {
        InternalSqlService sqlService = node.getNodeEngine().getSqlService();

        long sqlQueriesSubmittedCount = sqlService.getSqlQueriesSubmittedCount();
        context.collect(SQL_QUERIES_SUBMITTED, sqlQueriesSubmittedCount);

        long sqlStreamingQueriesExecutedCount = sqlService.getSqlStreamingQueriesExecutedCount();
        context.collect(SQL_STREAMING_QUERIES_EXECUTED, sqlStreamingQueriesExecutedCount);
    }
@Test
    public void test_SqlQueries() {
        // given
        when(sqlService.getSqlQueriesSubmittedCount()).thenReturn(5L);
        when(sqlService.getSqlStreamingQueriesExecutedCount()).thenReturn(3L);

        // when
        sqlMetricsProvider.provideMetrics(node, context);

        // then
        verify(context).collect(SQL_QUERIES_SUBMITTED, 5L);
        verify(context).collect(SQL_STREAMING_QUERIES_EXECUTED, 3L);
        verifyNoMoreInteractions(context);
    }