Java Lists类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中jersey.repackaged.com.google.common.collect.Lists类的典型用法代码示例。如果您正苦于以下问题：Java Lists类的具体用法？Java Lists怎么用？Java Lists使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Lists类属于jersey.repackaged.com.google.common.collect包，在下文中一共展示了Lists类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: StaticDatabaseMappingService

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
public StaticDatabaseMappingService(
    MetaStoreMappingFactory metaStoreMappingFactory,
    List<AbstractMetaStore> initialMetastores) {
  this.metaStoreMappingFactory = metaStoreMappingFactory;
  primaryDatabasesCache = CacheBuilder.newBuilder().expireAfterAccess(1, TimeUnit.MINUTES).maximumSize(1).build(
      new CacheLoader<String, List<String>>() {

        @Override
        public List<String> load(String key) throws Exception {
          if (primaryDatabaseMapping != null) {
            return primaryDatabaseMapping.getClient().get_all_databases();
          } else {
            return Lists.newArrayList();
          }
        }
      });
  init(initialMetastores);
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:19，代码来源:StaticDatabaseMappingService.java

示例2: setUp

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Before
public void setUp() {
  databaseMapping = new DatabaseMappingImpl(metastoreMapping);
  database = new Database();
  database.setName(DB_NAME);
  partition = new Partition();
  partition.setDbName(DB_NAME);
  partitions = Lists.newArrayList(partition);
  index = new Index();
  index.setDbName(DB_NAME);
  hiveObjectRef = new HiveObjectRef();
  hiveObjectRef.setDbName(DB_NAME);
  hiveObjectRef.setObjectType(HiveObjectType.DATABASE);
  hiveObjectRef.setObjectName(DB_NAME);
  hiveObjectPrivileges = new ArrayList<>();
  HiveObjectPrivilege hiveObjectPrivilege = new HiveObjectPrivilege();
  hiveObjectPrivilege.setHiveObject(hiveObjectRef);
  hiveObjectPrivileges.add(hiveObjectPrivilege);
  partitionSpec = new PartitionSpec();
  partitionSpec.setDbName(DB_NAME);
  when(metastoreMapping.transformInboundDatabaseName(DB_NAME)).thenReturn(IN_DB_NAME);
  when(metastoreMapping.transformOutboundDatabaseName(DB_NAME)).thenReturn(OUT_DB_NAME);
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:24，代码来源:DatabaseMappingImplTest.java

示例3: transformInboundSetPartitionStatsRequest

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void transformInboundSetPartitionStatsRequest() throws Exception {
  SetPartitionsStatsRequest setPartitionsStatsRequest = new SetPartitionsStatsRequest();
  ColumnStatistics columnStatistics = new ColumnStatistics();
  ColumnStatisticsDesc statsDesc = new ColumnStatisticsDesc();
  statsDesc.setDbName(DB_NAME);
  columnStatistics.setStatsDesc(statsDesc);
  setPartitionsStatsRequest.setColStats(Lists.newArrayList(columnStatistics));
  SetPartitionsStatsRequest result = databaseMapping
      .transformInboundSetPartitionStatsRequest(setPartitionsStatsRequest);
  assertThat(result, is(sameInstance(setPartitionsStatsRequest)));
  ColumnStatistics resultColStats = result.getColStats().get(0);
  assertThat(resultColStats, is(sameInstance(columnStatistics)));
  assertThat(resultColStats.getStatsDesc(), is(sameInstance(statsDesc)));
  assertThat(resultColStats.getStatsDesc().getDbName(), is(IN_DB_NAME));
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:17，代码来源:DatabaseMappingImplTest.java

示例4: panopticStoreOperationsHandlerGetAllDatabasesByPattern

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void panopticStoreOperationsHandlerGetAllDatabasesByPattern() throws Exception {
  String pattern = "*_db";
  when(primaryDatabaseClient.get_databases(pattern)).thenReturn(Lists.newArrayList("primary_db"));

  Iface federatedDatabaseClient = mock(Iface.class);
  when(metaStoreMappingFederated.getClient()).thenReturn(federatedDatabaseClient);
  when(metaStoreMappingFederated.transformOutboundDatabaseName("federated_db")).thenReturn("federated_db");
  when(federatedDatabaseClient.get_databases(pattern)).thenReturn(Lists.newArrayList("federated_db"));

  PanopticOperationHandler handler = service.getPanopticOperationHandler();
  List<String> allDatabases = handler.getAllDatabases(pattern);
  assertThat(allDatabases.size(), is(2));
  assertThat(allDatabases.contains("primary_db"), is(true));
  assertThat(allDatabases.contains("federated_db"), is(true));
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:17，代码来源:PrefixBasedDatabaseMappingServiceTest.java

示例5: panopticOperationsHandlerGetTableMeta

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void panopticOperationsHandlerGetTableMeta() throws Exception {
  List<String> tblTypes = Lists.newArrayList();
  TableMeta tableMeta = new TableMeta("federated_db", "tbl", null);

  Iface federatedDatabaseClient = mock(Iface.class);
  when(metaStoreMappingFederated.getClient()).thenReturn(federatedDatabaseClient);
  when(federatedDatabaseClient.get_table_meta("federated_*", "*", tblTypes))
      .thenReturn(Lists.newArrayList(tableMeta));
  when(metaStoreMappingFederated.transformOutboundDatabaseName("federated_db")).thenReturn("name_federated_db");

  PanopticOperationHandler handler = service.getPanopticOperationHandler();
  List<TableMeta> tableMetas = handler.getTableMeta("name_federated_*", "*", tblTypes);
  assertThat(tableMetas.size(), is(1));
  TableMeta tableMetaResult = tableMetas.get(0);
  assertThat(tableMetaResult, is(sameInstance(tableMeta)));
  assertThat(tableMetaResult.getDbName(), is("name_federated_db"));
  assertThat(tableMetaResult.getTableName(), is("tbl"));

  verify(primaryDatabaseClient).get_table_meta("name_federated_*", "*", tblTypes);
  verify(primaryDatabaseClient, never()).get_table_meta("federated_*", "*", tblTypes);
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:23，代码来源:PrefixBasedDatabaseMappingServiceTest.java

示例6: onUpdatePrimary

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void onUpdatePrimary() throws Exception {
  PrimaryMetaStore newMetastore = newPrimaryInstance("newPrimary", "abc");
  MetaStoreMapping newMapping = mockNewMapping(true, newMetastore);
  Iface newClient = mock(Iface.class);
  when(newClient.get_all_databases()).thenReturn(Lists.newArrayList("primary_db"));
  when(newMapping.getClient()).thenReturn(newClient);
  when(metaStoreMappingFactory.newInstance(newMetastore)).thenReturn(newMapping);

  service.onUpdate(primaryMetastore, newMetastore);

  DatabaseMapping databaseMapping = service.databaseMapping("primary_db");
  assertThat(databaseMapping.getMetastoreMappingName(), is("newPrimary"));
  assertTrue(databaseMapping instanceof IdentityMapping);

  // unchanged
  databaseMapping = service.databaseMapping("federateddb");
  assertThat(databaseMapping.getMetastoreMappingName(), is(FEDERATED_NAME));
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:20，代码来源:StaticDatabaseMappingServiceTest.java

示例7: panopticOperationsHandlerGetTableMeta

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void panopticOperationsHandlerGetTableMeta() throws Exception {
  String pattern = "pattern";
  List<String> tblTypes = Lists.newArrayList();
  TableMeta tableMeta1 = mockTableMeta("primary_db");
  TableMeta tableMeta2 = mockTableMeta("federateddb");
  TableMeta tableMeta3Ignored = mockTableMeta("non_mapped_db");

  when(primaryDatabaseClient.get_table_meta(pattern, pattern, tblTypes)).thenReturn(Lists.newArrayList(tableMeta1));

  Iface federatedDatabaseClient = mock(Iface.class);
  when(metaStoreMappingFederated.getClient()).thenReturn(federatedDatabaseClient);
  when(federatedDatabaseClient.get_table_meta(pattern, pattern, tblTypes))
      .thenReturn(Lists.newArrayList(tableMeta2, tableMeta3Ignored));

  PanopticOperationHandler handler = service.getPanopticOperationHandler();
  List<TableMeta> allTableMetas = Lists.newArrayList(tableMeta1, tableMeta2);
  assertThat(handler.getTableMeta(pattern, pattern, tblTypes), is(allTableMetas));
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:20，代码来源:StaticDatabaseMappingServiceTest.java

示例8: testThrowsExecptionWhenSearchDomainDoesNotExist

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void testThrowsExecptionWhenSearchDomainDoesNotExist() {
    when(amazonCloudSearch.describeDomains(any()))
            .thenReturn(new DescribeDomainsResult().withDomainStatusList(Lists.newArrayList()));

    try {
        // TODO suppress exception stacktrace
        getService(ModelIndexer.class);
    } catch (MultiException e) {
        assertEquals("Could not find CloudSearch domain: test-model", e.getCause().getMessage());

        return;
    }

    fail("Was expection an exception");
}

开发者ID:coding4people，项目名称:mosquito-report-api，代码行数:17，代码来源:IndexerTest.java

示例9: testThrowsExecptionWhenSearchServiceDoesNotExist

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void testThrowsExecptionWhenSearchServiceDoesNotExist() {
    when(amazonCloudSearch.describeDomains(any())).thenReturn(new DescribeDomainsResult()
            .withDomainStatusList(Lists.newArrayList(new DomainStatus().withSearchService(new ServiceEndpoint()))));

    try {
        // TODO suppress exception stacktrace
        getService(ModelIndexer.class);
    } catch (MultiException e) {
        assertEquals("Could not find SearchService for: test-model", e.getCause().getMessage());

        return;
    }

    fail("Was expection an exception");
}

开发者ID:coding4people，项目名称:mosquito-report-api，代码行数:17，代码来源:IndexerTest.java

示例10: testSearchCenter

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void testSearchCenter() {
    when(amazonCloudSearch.describeDomains(any())).thenReturn(new DescribeDomainsResult()
            .withDomainStatusList(Lists.newArrayList(new DomainStatus().withSearchService(new ServiceEndpoint().withEndpoint("http://localhost")))));

    HashMap<String, List<String>> map = Maps.newHashMap();
    map.put("property", Lists.newArrayList("value"));
    SearchResult expected = new SearchResult().withHits(new Hits().withHit(new Hit().withFields(map)));
    
    ArgumentCaptor<SearchRequest> requestCaptor = ArgumentCaptor.forClass(SearchRequest.class);
    
    when(domain.search(requestCaptor.capture())).thenReturn(expected);
    
    List<ObjectNode> result = getService(ModelIndexer.class).searchCenter("0,0");
    
    SearchRequest request = requestCaptor.getValue();
    
    assertEquals("value", result.get(0).get("property").asText());
    assertEquals("latlon:['0.1,-0.1','-0.1,0.1']", request.getQuery());
    assertEquals("{\"distance\":\"haversin(0.0,0.0,latlon.latitude,latlon.longitude)\"}", request.getExpr());
    assertEquals("distance asc", request.getSort());
    assertEquals(Long.valueOf(30L), request.getSize());
}

开发者ID:coding4people，项目名称:mosquito-report-api，代码行数:24，代码来源:IndexerTest.java

示例11: testQuery

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void testQuery() {
    FocusQueryInput data = new FocusQueryInput();
    data.setLatlonnw("36.628611,-121.694152");
    data.setLatlonse("34.628611,-119.694152");

    List<ObjectNode> list = Lists
            .<ObjectNode> newArrayList(new ObjectMapper().createObjectNode().put("property", "value"));
    when(focusIndexer.search("36.628611,-121.694152", "34.628611,-119.694152")).thenReturn(list);

    Response response = target().path("/focus/query").request().post(Entity.json(data));

    assertEquals(200, response.getStatus());
    assertEquals("application/json;charset=UTF-8", response.getHeaderString("Content-type"));

    verify(focusIndexer).search("36.628611,-121.694152", "34.628611,-119.694152");

    ArrayNode result = response.readEntity(ArrayNode.class);

    assertEquals("value", result.get(0).get("property").asText());
}

开发者ID:coding4people，项目名称:mosquito-report-api，代码行数:22，代码来源:FocusControllerTest.java

示例12: testQueryCenter

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void testQueryCenter() {
    FocusCenterInput data = new FocusCenterInput();
    data.setLatlon("36.628611,-121.694152");

    List<ObjectNode> list = Lists
            .<ObjectNode> newArrayList(new ObjectMapper().createObjectNode().put("property", "value"));
    when(focusIndexer.searchCenter("36.628611,-121.694152")).thenReturn(list);

    Response response = target().path("/focus/query-center").request().post(Entity.json(data));

    assertEquals(200, response.getStatus());
    assertEquals("application/json;charset=UTF-8", response.getHeaderString("Content-type"));

    verify(focusIndexer).searchCenter("36.628611,-121.694152");

    ArrayNode result = response.readEntity(ArrayNode.class);

    assertEquals("value", result.get(0).get("property").asText());
}

开发者ID:coding4people，项目名称:mosquito-report-api，代码行数:21，代码来源:FocusControllerTest.java

示例13: getScores

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Override
public Map<EntityPair, Double> getScores(final Set<CouplingInstance> instances) {
	Map<EntityPair, Double> resultPerCC = new HashMap<>();
	// compare all characteristics with each other
	List<CouplingInstance> characteristics = Lists.newArrayList(instances);

	for (int i = 0; i < characteristics.size() - 1; i++) {
		for (int j = i + 1; j < characteristics.size(); j++) {
			// for all nanoentities in two different characteristics,
			// calculate the distance
			CouplingInstance characteristicI = characteristics.get(i);
			CouplingInstance characteristicJ = characteristics.get(j);
			for (Nanoentity nanoentityFromI : characteristicI.getAllNanoentities()) {
				for (Nanoentity nanoentityFromJ : characteristicJ.getAllNanoentities()) {
					int distance = Math.abs(characteristicI.getCharacteristic().getWeight() - characteristicJ.getCharacteristic().getWeight());
					if (distance != 0) {
						resultPerCC.put(new EntityPair(nanoentityFromI, nanoentityFromJ), distance * -1d);
					}

				}
			}
		}
	}
	return resultPerCC;
}

开发者ID:ServiceCutter，项目名称:ServiceCutter，代码行数:26，代码来源:CharacteristicsCriteriaScorer.java

示例14: getRecipients

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
/**
 * recipients
 * includes owner, collaborator, commented users
 */
private List<Account> getRecipients(IssuePK issuePK) {
  Set<String> userNames = new HashSet<>();

  Repository repository = emProvider.get().find(Repository.class, issuePK.getRepositoryPK());
  userNames.addAll(repository.getAllOwners());

  userNames.addAll(collaboratorService.getNames(repository.getPk()));

  List<IssueComment> issueComments = emProvider.get().createNamedQuery("IssueComment.list", IssueComment.class)
      .setParameter("issuePK", issuePK)
      .getResultList();
  userNames.addAll(Lists.transform(issueComments, IssueComment::getCommentAccountName));

  return emProvider.get().createNamedQuery("Account.findIncluded", Account.class)
      .setParameter("names", userNames)
      .getResultList()
      .stream()
      .filter(account -> !account.isDeleted() && account.getUserAccount() != null)
      .collect(Collectors.toList());
}

开发者ID:kamegu，项目名称:git-webapp，代码行数:25，代码来源:NoticeService.java

示例15: registerMediaHandlers

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
private void registerMediaHandlers(){

        // register media play handlers
        IMediaPresenterService mediaPresenterService = ServiceProvider.Resolve(IMediaPresenterService.class);

        // register the internal image viewer

        IMediaHandler internalImageHandler = new ImageOpenHandler();
        mediaPresenterService.chainMediaHandler(internalImageHandler);

        // register external video players

        List<MediaPlayerCommand> externalPlayers =  Lists.newArrayList(VidadaClientSettings.instance().getExternalMediaPlayers());;
        Collections.reverse(externalPlayers);

        for(MediaPlayerCommand playerCommand : externalPlayers){
            IMediaHandler mediaHandler = new ExternalVideoProgramHandler(
                    playerCommand.getPlayerName(),
                    playerCommand.getCommand());
            mediaPresenterService.chainMediaHandler(mediaHandler);
        }
    }

开发者ID:Vidada-Project，项目名称:vidada-desktop，代码行数:23，代码来源:ApplicationFX.java

示例16: configure

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Override
@SneakyThrows
protected Application configure() {
	ResourceConfig rs = new ResourceConfig(TestResource.class, JacksonFeature.class);

	CORSFeature corsFeature = new CORSFeature(new OriginFilter.Default(
			Lists.newArrayList(new URL("http://localhost:8080")), Lists.newArrayList("0.0.0.0")));
	rs.register(corsFeature);
	return rs;
}

开发者ID:Mercateo，项目名称:rest-jersey-utils，代码行数:11，代码来源:CorsFeatureIntegrationTest.java

示例17: testIsOriginAllowedString

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void testIsOriginAllowedString() throws Exception {

	OriginFilter originFilter = new OriginFilter.Default(Lists.newArrayList(new URL("http://localhost:8080")),
			Lists.newArrayList("0.0.0.0"));
	assertTrue(originFilter.isOriginAllowed("http://localhost:8080"));
	assertTrue(originFilter.isOriginAllowed("http://0.0.0.0:8080"));

	assertFalse(originFilter.isOriginAllowed("http://localhost:8081"));
	assertFalse(originFilter.isOriginAllowed("this is no URL"));
}

开发者ID:Mercateo，项目名称:rest-jersey-utils，代码行数:12，代码来源:OriginFilterTest.java

示例18: testIsOriginAllowedURL

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void testIsOriginAllowedURL() throws Exception {
	OriginFilter originFilter = new OriginFilter.Default(Lists.newArrayList(new URL("http://localhost:8080")),
			Lists.newArrayList("0.0.0.0"));
	assertTrue(originFilter.isOriginAllowed(new URL("http://localhost:8080")));
	assertTrue(originFilter.isOriginAllowed(new URL("http://0.0.0.0:8080")));

	assertFalse(originFilter.isOriginAllowed(new URL("http://localhost:8081")));

}

开发者ID:Mercateo，项目名称:rest-jersey-utils，代码行数:11，代码来源:OriginFilterTest.java

示例19: transformInboundLockRequest

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void transformInboundLockRequest() throws Exception {
  LockRequest lockRequest = new LockRequest();
  LockComponent lockComponent = new LockComponent();
  lockComponent.setDbname(DB_NAME);
  List<LockComponent> components = Lists.newArrayList(lockComponent);
  lockRequest.setComponent(components);
  LockRequest result = databaseMapping.transformInboundLockRequest(lockRequest);
  assertThat(result, is(sameInstance(lockRequest)));
  List<LockComponent> resultComponents = result.getComponent();
  assertThat(resultComponents, is(sameInstance(components)));
  LockComponent resultComponent = resultComponents.get(0);
  assertThat(resultComponent, is(sameInstance(lockComponent)));
  assertThat(resultComponent.getDbname(), is(IN_DB_NAME));
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:16，代码来源:DatabaseMappingImplTest.java

示例20: transformInboundPartitionSpecs

import jersey.repackaged.com.google.common.collect.Lists; //导入依赖的package包/类
@Test
public void transformInboundPartitionSpecs() throws Exception {
  List<PartitionSpec> partitionSpecs = Lists.newArrayList(partitionSpec);
  List<PartitionSpec> result = databaseMapping.transformInboundPartitionSpecs(partitionSpecs);
  assertThat(result, is(sameInstance(partitionSpecs)));
  PartitionSpec resultSpec = result.get(0);
  assertThat(resultSpec, is(sameInstance(partitionSpec)));
  assertThat(resultSpec.getDbName(), is(IN_DB_NAME));
}

开发者ID:HotelsDotCom，项目名称:waggle-dance，代码行数:10，代码来源:DatabaseMappingImplTest.java

注：本文中的jersey.repackaged.com.google.common.collect.Lists类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。