@Test (dependsOnMethods = "createFlowSpec") void testExist() throws Exception { Assert.assertTrue(flowCatalog.exists(flowSpec.getUri())); }
public boolean exists(URI uri) { try { return specStore.exists(uri); } catch (IOException e) { throw new RuntimeException("Cannot retrieve Spec from Spec store for URI: " + uri, e); } }
FlowCatalog extends AbstractIdleService implements SpecCatalog, MutableSpecCatalog { public boolean exists(URI uri) { try { return specStore.exists(uri); } catch (IOException e) { throw new RuntimeException("Cannot retrieve Spec from Spec store for URI: " + uri, e); } } }
FlowCatalog extends AbstractIdleService implements SpecCatalog, MutableSpecCatalog { public boolean exists(URI uri) { try { return specStore.exists(uri); } catch (IOException e) { throw new RuntimeException("Cannot retrieve Spec from Spec store for URI: " + uri, e); } } FlowCatalog(Config config);  FlowCatalog(Config config, Optional<Logger> log);  FlowCatalog(Config config, GobblinInstanceEnvironment env);  FlowCatalog(Config config, Optional<Logger> log, Optional<MetricContext> parentMetricContext,
      boolean instrumentationEnabled); }
FlowCatalog extends AbstractIdleService implements SpecCatalog, MutableSpecCatalog { public boolean exists(URI uri) { try { return specStore.exists(uri); } catch (IOException e) { throw new RuntimeException("Cannot retrieve Spec from Spec store for URI: " + uri, e); } } FlowCatalog(Config config);  FlowCatalog(Config config, Optional<Logger> log);  FlowCatalog(Config config, GobblinInstanceEnvironment env);  FlowCatalog(Config config, Optional<Logger> log, Optional<MetricContext> parentMetricContext,
      boolean instrumentationEnabled); @Override void addListener(SpecCatalogListener specListener); @Override void removeListener(SpecCatalogListener specCatalogListener); @Override void registerWeakSpecCatalogListener(SpecCatalogListener specCatalogListener); @Nonnull @Override MetricContext getMetricContext(); @Override boolean isInstrumentationEnabled(); @Override List<Tag<?>> generateTags(org.apache.gobblin.configuration.State state); @Override void switchMetricContext(List<Tag<?>> tags); @Override void switchMetricContext(MetricContext context); @Override SpecCatalog.StandardMetrics getMetrics(); Iterator<URI> getSpecURIs(); Iterator<URI> getSpecURISWithTag(String tag); @Deprecated @Override Collection<Spec> getSpecs(); boolean exists(URI uri); @Override Spec getSpecs(URI uri); @Override Collection<Spec> getSpecs(SpecSearchObject specSearchObject); Collection<Spec> getAllSpecs(); Spec getSpecWrapper(URI uri); Map<String, AddSpecResponse> put(Spec spec, boolean triggerListener); static boolean isCompileSuccessful(Map<String, AddSpecResponse> responseMap); static boolean isCompileSuccessful(String dag); @Override Map<String, AddSpecResponse> put(Spec spec); void remove(URI uri); @Override void remove(URI uri, Properties headers); void remove(URI uri, Properties headers, boolean triggerListener); Object getSyncObject(String specUri); }
FlowCatalog extends AbstractIdleService implements SpecCatalog, MutableSpecCatalog { public boolean exists(URI uri) { try { return specStore.exists(uri); } catch (IOException e) { throw new RuntimeException("Cannot retrieve Spec from Spec store for URI: " + uri, e); } } FlowCatalog(Config config);  FlowCatalog(Config config, Optional<Logger> log);  FlowCatalog(Config config, GobblinInstanceEnvironment env);  FlowCatalog(Config config, Optional<Logger> log, Optional<MetricContext> parentMetricContext,
      boolean instrumentationEnabled); @Override void addListener(SpecCatalogListener specListener); @Override void removeListener(SpecCatalogListener specCatalogListener); @Override void registerWeakSpecCatalogListener(SpecCatalogListener specCatalogListener); @Nonnull @Override MetricContext getMetricContext(); @Override boolean isInstrumentationEnabled(); @Override List<Tag<?>> generateTags(org.apache.gobblin.configuration.State state); @Override void switchMetricContext(List<Tag<?>> tags); @Override void switchMetricContext(MetricContext context); @Override SpecCatalog.StandardMetrics getMetrics(); Iterator<URI> getSpecURIs(); Iterator<URI> getSpecURISWithTag(String tag); @Deprecated @Override Collection<Spec> getSpecs(); boolean exists(URI uri); @Override Spec getSpecs(URI uri); @Override Collection<Spec> getSpecs(SpecSearchObject specSearchObject); Collection<Spec> getAllSpecs(); Spec getSpecWrapper(URI uri); Map<String, AddSpecResponse> put(Spec spec, boolean triggerListener); static boolean isCompileSuccessful(Map<String, AddSpecResponse> responseMap); static boolean isCompileSuccessful(String dag); @Override Map<String, AddSpecResponse> put(Spec spec); void remove(URI uri); @Override void remove(URI uri, Properties headers); void remove(URI uri, Properties headers, boolean triggerListener); Object getSyncObject(String specUri); static final String FLOWSPEC_STORE_CLASS_KEY; static final String FLOWSPEC_STORE_DIR_KEY; static final String DEFAULT_FLOWSPEC_STORE_CLASS; static final String FLOWSPEC_SERDE_CLASS_KEY; static final String DEFAULT_FLOWSPEC_SERDE_CLASS; }