@Test public void testGetShimIdentifiers() { List<ShimIdentifierInterface> shimIdentifiers = hadoopClusterManager.getShimIdentifiers(); assertNotNull( shimIdentifiers ); assertThat( shimIdentifiers.size(), equalTo( 2 ) ); assertFalse( shimIdentifiers.contains( internalShim ) ); }
List<ShimIdentifierInterface> getShimIdentifiers() { List<ShimIdentifierInterface> shims = shimIdentifiersSupplier.get().stream() .filter( s -> !internalShim.equals( s.getId() ) ) .collect( Collectors.toList() ); shims.sort( Comparator.comparing( ShimIdentifierInterface::getVendor ) ); return shims; }
HadoopClusterManager implements RuntimeTestProgressCallback { List<ShimIdentifierInterface> getShimIdentifiers() { List<ShimIdentifierInterface> shims = shimIdentifiersSupplier.get().stream() .filter( s -> !internalShim.equals( s.getId() ) ) .collect( Collectors.toList() ); shims.sort( Comparator.comparing( ShimIdentifierInterface::getVendor ) ); return shims; } }
HadoopClusterManager implements RuntimeTestProgressCallback { List<ShimIdentifierInterface> getShimIdentifiers() { List<ShimIdentifierInterface> shims = shimIdentifiersSupplier.get().stream() .filter( s -> !internalShim.equals( s.getId() ) ) .collect( Collectors.toList() ); shims.sort( Comparator.comparing( ShimIdentifierInterface::getVendor ) ); return shims; } HadoopClusterManager( Spoon spoon, NamedClusterService namedClusterService, IMetaStore metaStore,
                               String internalShim ); }
HadoopClusterManager implements RuntimeTestProgressCallback { List<ShimIdentifierInterface> getShimIdentifiers() { List<ShimIdentifierInterface> shims = shimIdentifiersSupplier.get().stream() .filter( s -> !internalShim.equals( s.getId() ) ) .collect( Collectors.toList() ); shims.sort( Comparator.comparing( ShimIdentifierInterface::getVendor ) ); return shims; } HadoopClusterManager( Spoon spoon, NamedClusterService namedClusterService, IMetaStore metaStore,
                               String internalShim ); JSONObject importNamedCluster( ThinNameClusterModel model,
                                        Map<String, CachedFileItemStream> siteFilesSource ); JSONObject createNamedCluster( ThinNameClusterModel model,
                                        Map<String, CachedFileItemStream> siteFilesSource ); JSONObject editNamedCluster( ThinNameClusterModel model, boolean isEditMode,
                                      Map<String, CachedFileItemStream> siteFilesSource ); ThinNameClusterModel getNamedCluster( String namedCluster ); JSONObject installDriver( FileItemStream driver ); boolean isValidConfigurationFile( String fileName ); void deleteNamedCluster( IMetaStore metaStore, String namedCluster, boolean refreshTree ); Object runTests( RuntimeTester runtimeTester, String namedCluster ); void onProgress( final RuntimeTestStatus clusterTestStatus ); }
HadoopClusterManager implements RuntimeTestProgressCallback { List<ShimIdentifierInterface> getShimIdentifiers() { List<ShimIdentifierInterface> shims = shimIdentifiersSupplier.get().stream() .filter( s -> !internalShim.equals( s.getId() ) ) .collect( Collectors.toList() ); shims.sort( Comparator.comparing( ShimIdentifierInterface::getVendor ) ); return shims; } HadoopClusterManager( Spoon spoon, NamedClusterService namedClusterService, IMetaStore metaStore,
                               String internalShim ); JSONObject importNamedCluster( ThinNameClusterModel model,
                                        Map<String, CachedFileItemStream> siteFilesSource ); JSONObject createNamedCluster( ThinNameClusterModel model,
                                        Map<String, CachedFileItemStream> siteFilesSource ); JSONObject editNamedCluster( ThinNameClusterModel model, boolean isEditMode,
                                      Map<String, CachedFileItemStream> siteFilesSource ); ThinNameClusterModel getNamedCluster( String namedCluster ); JSONObject installDriver( FileItemStream driver ); boolean isValidConfigurationFile( String fileName ); void deleteNamedCluster( IMetaStore metaStore, String namedCluster, boolean refreshTree ); Object runTests( RuntimeTester runtimeTester, String namedCluster ); void onProgress( final RuntimeTestStatus clusterTestStatus ); static final String STRING_NAMED_CLUSTERS; static final String PLACEHOLDER_VALUE; }