@Test public void testImplicitBroker() { Assert.assertEquals(SharedResourcesBrokerFactory.getImplicitBroker(), IMPLICIT); ExecutorService executorService = Executors.newSingleThreadExecutor(); Future<?> future = executorService.submit(new ImplicitBrokerTest()); try { future.get(); } catch (ExecutionException | InterruptedException ee) { throw new RuntimeException(ee); } executorService.shutdownNow(); }
public static SharedResourcesBroker<?> getImplicitBroker() { SharedResourcesBroker<?> threadLocal = threadLocalBroker.get(); return threadLocal == null ? getSingleton() : threadLocal; }
SharedResourcesBrokerFactory { public static SharedResourcesBroker<?> getImplicitBroker() { SharedResourcesBroker<?> threadLocal = threadLocalBroker.get(); return threadLocal == null ? getSingleton() : threadLocal; } }
SharedResourcesBrokerFactory { public static SharedResourcesBroker<?> getImplicitBroker() { SharedResourcesBroker<?> threadLocal = threadLocalBroker.get(); return threadLocal == null ? getSingleton() : threadLocal; }  }
SharedResourcesBrokerFactory { public static SharedResourcesBroker<?> getImplicitBroker() { SharedResourcesBroker<?> threadLocal = threadLocalBroker.get(); return threadLocal == null ? getSingleton() : threadLocal; }  static SharedResourcesBrokerImpl<S> createDefaultTopLevelBroker(Config config,
      ScopeInstance<S> globalScope); static SharedResourcesBroker<?> getImplicitBroker(); static void registerImplicitBroker(SharedResourcesBroker<?> broker); static void addBrokerKeys(Map<String, String> configMap, Iterable<Map.Entry<S, T>> entries); }
SharedResourcesBrokerFactory { public static SharedResourcesBroker<?> getImplicitBroker() { SharedResourcesBroker<?> threadLocal = threadLocalBroker.get(); return threadLocal == null ? getSingleton() : threadLocal; }  static SharedResourcesBrokerImpl<S> createDefaultTopLevelBroker(Config config,
      ScopeInstance<S> globalScope); static SharedResourcesBroker<?> getImplicitBroker(); static void registerImplicitBroker(SharedResourcesBroker<?> broker); static void addBrokerKeys(Map<String, String> configMap, Iterable<Map.Entry<S, T>> entries); static final String LOAD_HADOOP_CONFIGURATION; static final String BROKER_CONF_FILE_KEY; static final String DEFAULT_BROKER_CONF_FILE; }