DataServiceClient implements IDataServiceClientService { public List<DataServiceMeta> getServiceMeta() { List<DataServiceMeta> services = Lists.newArrayList(); for ( DataServiceMeta serviceMeta : resolver.getDataServices( logErrors()::apply ) ) { services.add( serviceMeta ); } return services; } DataServiceClient( Query.Service queryService, DataServiceResolver resolver,
                            ExecutorService executorService ); @Override DataInputStream query( String sqlQuery, final int maxRows ); @Override DataInputStream query( String sqlQuery, final int maxRows,
                                          Map<String, String> params ); @Override DataInputStream query( String sqlQuery, IDataServiceClientService.StreamingMode windowMode,
                                          long windowSize, long windowEvery,
                                          long windowLimit ); @Override DataInputStream query( String sqlQuery, IDataServiceClientService.StreamingMode windowMode,
                                          long windowSize, long windowEvery,
                                          long windowLimit, Map<String, String> params ); Query prepareQuery( String sql, int maxRows, Map<String, String> parameters ); Query prepareQuery( String sql, IDataServiceClientService.StreamingMode windowMode,
                             long windowSize, long windowEvery, long windowLimit, Map<String, String> parameters ); @Override List<IThinServiceInformation> getServiceInformation(); @Override ThinServiceInformation getServiceInformation( String name ); @Override List<String> getServiceNames( String serviceName ); @Override List<String> getServiceNames(); List<DataServiceMeta> getServiceMeta(); DataServiceMeta getServiceMeta( String serviceName ); void setLogChannel( LogChannelInterface log ); LogChannelInterface getLogChannel(); @Deprecated void setRepository( Repository repository ); @Deprecated void setMetaStore( IMetaStore metaStore ); @Override void query( String sqlQuery, IStreamingParams streamParams,
                     Map<String, String> params, Observer<List<RowMetaAndData>> consumer );  }
@Test public void testGetServiceMeta() throws Exception { assertThat( client.getServiceMeta(), contains( dataService, streamingDataService ) ); }
@Test public void testGetServiceMetaByName() throws Exception { DataServiceMeta serviceMetaRegular = client.getServiceMeta( DATA_SERVICE_NAME ); DataServiceMeta serviceMetaStreaming = client.getServiceMeta( STREAMING_DATA_SERVICE_NAME ); assertSame( serviceMetaRegular, dataService ); assertSame( serviceMetaStreaming, streamingDataService ); }