org.apache.atlas.repository.impexp.ZipSink.add()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 12:56:44 28 4

@Test
public void recordsEntityEntries() throws AtlasBaseException {
  ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
  ZipSink zs = new ZipSink(byteOutputStream);
  AtlasEntity entity = new AtlasEntity();
  entity.setGuid(String.format(knownEntityGuidFormat, 0));
  zs.add(entity);
  assertTrue(zs.hasEntity(String.format(knownEntityGuidFormat, 0)));
  zs.close();
}

private void addEntity(AtlasEntityWithExtInfo entity, ExportContext context) throws AtlasBaseException {
  if(context.sink.hasEntity(entity.getEntity().getGuid())) {
    return;
  }
  context.sink.add(entity);
  context.result.incrementMeticsCounter(String.format("entity:%s", entity.getEntity().getTypeName()));
  if(entity.getReferredEntities() != null) {
    for (AtlasEntity e: entity.getReferredEntities().values()) {
      context.result.incrementMeticsCounter(String.format("entity:%s", e.getTypeName()));
    }
  }
  context.result.incrementMeticsCounter("entity:withExtInfo");
  context.reportProgress();
}

@Test
public void recordsEntityWithExtInfoEntries() throws AtlasBaseException {
  final int max_entries = 3;
  ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
  ZipSink zs = new ZipSink(byteOutputStream);
  AtlasEntity entity = new AtlasEntity();
  entity.setGuid(String.format(knownEntityGuidFormat, 0));
  AtlasEntity.AtlasEntityWithExtInfo entityWithExtInfo = new AtlasEntity.AtlasEntityWithExtInfo(entity);
  addReferredEntities(entityWithExtInfo, max_entries);
  zs.add(entityWithExtInfo);
  for (int i = 0; i <= max_entries; i++) {
    String g = String.format(knownEntityGuidFormat, i);
    assertTrue(zs.hasEntity(g));
  }
  zs.close();
}

@Test
public void recordsEntityWithExtInfoEntries() throws AtlasBaseException {
  final int max_entries = 3;
  ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
  ZipSink zs = new ZipSink(byteOutputStream);
  AtlasEntity entity = new AtlasEntity();
  entity.setGuid(String.format(knownEntityGuidFormat, 0));
  AtlasEntity.AtlasEntityWithExtInfo entityWithExtInfo = new AtlasEntity.AtlasEntityWithExtInfo(entity);
  addReferredEntities(entityWithExtInfo, max_entries);
  zs.add(entityWithExtInfo);
  for (int i = 0; i <= max_entries; i++) {
    String g = String.format(knownEntityGuidFormat, i);
    assertTrue(zs.hasEntity(g));
  }
  zs.close();
}

28 4 0

• apache-atlas - 独立运行 Apache Atlas

  我正在尝试在 Ubuntu 上以独立方式运行 Apache Atlas - 这意味着无需设置 Solr 和/或 HBase。 我所做的(根据文档: http://atlas.apache.org/0.

• mongodb-atlas - mongodb atlas alert的调试流程

  我对 mongodb 和 atlas 还很陌生，对以下警报感到困惑 Query Targeting: Scanned Objects / Returned has gone above 1000 我希

• mongodb-atlas - 连接到 Mongo Atlas 中学

  在 Cloud Mongo (Mongo Atlas) 免费层上，它有 3 个服务器成员。如何从 Mongo shell 连接到 Secondary 主机？他们的例子只展示了如何连接到 Primary

• apache-atlas - 将元数据从 RDBMS 导入 Apache Atlas

  我正在学习 Atlas 并试图找到一种从 RDBMS(如(Sql Server 或 Postgre Sql))导入元数据的方法。 有人可以提供引用或步骤吗？ 我在 docker 中使用 Atlas 并

• android - “com.layer.atlas:layer-atlas”有什么问题？

  现在我无法解决依赖性，怎么了？ 公司会更改名称吗？但是，我在他们的网站上看到它，但没有“com.layer.atlas:layer-atlas”，但是我的应用程序包含此依赖项，谁能告诉我原因？ 最佳答

• mongodb-atlas-search - 在 MongoDB Atlas 全文搜索中查询词的子集

  我的目标是创建一个索引 + 搜索管道，因此我可以通过搜索“reprod”找到以下文档: { name: "can you find this and reproduce?" } 我有什么: 我正在使用

• mongodb-atlas-search - 在 MongoDB Atlas 全文搜索中查询词的子集

  我的目标是创建一个索引 + 搜索管道，因此我可以通过搜索“reprod”找到以下文档: { name: "can you find this and reproduce?" } 我有什么: 我正在使用

• mongodb - MongoDB Atlas 和 MongoDB Atlas for AWS 有什么区别

  在调查用于物联网数据存储的兼容数据库时，我查看了 MongoDB，发现定价有点令人困惑。 只是想知道 MongoDB Atlas 之间有什么区别？和 MongoDB Atlas for AWS因为他们

• mongodb - 我是 mongoDB Atlas 的新手，现在我想知道如何删除我的 MongoDB Atlas 项目

  当我点击删除按钮时，它显示: 错误信息:“项目名称”有正在运行的 Atlas 集群。在删除项目之前，需要终止所有 Atlas 集群。如下图所示: 最佳答案 这真的很容易。您只需要在删除项目之前终止集群

• mongodb-atlas - 将 Google Cloud Run 连接到 MongoDB Atlas

  我正在评估从 Google Kubernetes Engine 迁移到 Google Cloud Run，以提高我们公司内部的成本和资源效率。我还在将我们的工作流从单一的 PHP 和 Ruby 应用程

• mongodb - 将本地 mongo db 迁移到 atlas 后无法从 atlas 获取记录

  我使用以下过程将本地数据库迁移到图集 使用 mongoexport --db bla 将数据库集合一一导出 --collection usersettings --jsonArray --out ~/

• atlassian-plugin-sdk - Atlassian SDK 中的 atlas-run 和 atlas-run-standalone 之间的实际区别是什么？

  Atlassian plugin SDK用于为 Atlassian 产品创建插件。 该套件包括两个程序，atlas-run和 atlas-run-standalone似乎执行相同的任务:在其中一个产品

• $limit and $count not working when using $seach & $match together - Atlas Search(同时使用$seach和$Match时，$Limit和$count不起作用-Atlas Search)

  如果结果是40，那么将结果限制为10也会将MATCHED_COUNT更改为10，而实际上它应该是40。关于atlas搜索的Mongoose文档非常有限，不包括这样的情况。如果你遇到过类似的问题，如果你

• Use $search instead of $match when using $in conditions in MongoDB Atlas Search(在MongoDB Atlas Search中使用$in条件时，请使用$Search而不是$Match)

  在最近的一次培训中，我了解了使用$earch操作符的好处。我想修改我的$Match查询以使用$Search。但是，我找不到与$in运算符等效的运算符。。当字段需要匹配单个对象ID时，这是没有问题的，我

• MongoDB ATLAS 到本地的迁移

  我们如何以最短的停机时间将数据从 MongoDB ATLAS 迁移到本地？我们可以使用 mongomirror 从本地迁移到 ATLAS。是否有任何类似的工具可以将日期从 MongoDB ATLAS

• docker - GKE无法到达MongoDB Atlas

  我在尝试将容器化的应用程序部署到GKE时遇到问题。它无法访问我的MongoDB Atlas集群。在本地运行Docker容器不会产生任何问题，并且运行良好。我绝不是Docker或Kubernetes的专

• ios - iOS框架找不到Texture Atlas

  在我尝试将我的 Assets ( Sprite 表)放入 iOS 框架之前，一切都运行良好。我正在使用 Swift 3.0 为了减轻我的 Xcode 项目的负担，我决定将我的 Assets :Text

• swift - 如何将vapor连接到mongodb atlas

  所以我有一个 vapor\fluent 应用程序可以很好地与本地 mongo 实例一起工作，这是当前的 mongo.json: { "database" : "vapor", "por

• javascript - 如何从firebase云功能连接到MongoDb Atlas

  我正在尝试关注this答案是从云函数连接到 mongodb atlas 数据库。 我使用上面答案中的代码: import { MongoClient } from 'mongodb' const ur

• mongodb - 一次删除多个文档mongodb atlas

  我一次只删除 Mongodb 云数据库(Atlas)中的一条记录。我有 60 条记录要删除，这很痛苦。我没有看到一次删除多条记录的明显方法。有没有简单的方法可以做到这一点？ 最佳答案 您实际上无法在