本文整理汇总了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;未经允许,请勿转载。 |
请发表评论