gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-13 10:11:58 25 4
gpt4 key购买 nike

本文整理了Java中org.apache.atlas.repository.impexp.ZipExportFileNames.toString()方法的一些代码示例,展示了ZipExportFileNames.toString()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZipExportFileNames.toString()方法的具体详情如下:
包路径:org.apache.atlas.repository.impexp.ZipExportFileNames
类名称:ZipExportFileNames
方法名:toString

ZipExportFileNames.toString介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-atlas

public AtlasExportResult getExportResult() throws AtlasBaseException {
  final String fileName = ZipExportFileNames.ATLAS_EXPORT_INFO_NAME.toString();
  String s = getFromCache(fileName);
  return convertFromJson(AtlasExportResult.class, s);
}

代码示例来源:origin: apache/incubator-atlas

public AtlasTypesDef getTypesDef() throws AtlasBaseException {
  final String fileName = ZipExportFileNames.ATLAS_TYPESDEF_NAME.toString();
  String s = (String) getFromCache(fileName);
  return convertFromJson(AtlasTypesDef.class, s);
}

代码示例来源:origin: apache/incubator-atlas

private void setCreationOrder() {
  String fileName = ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString();
  try {
    String s = getFromCache(fileName);
    this.creationOrder = convertFromJson(List.class, s);
    this.iterator = this.creationOrder.iterator();
  } catch (AtlasBaseException e) {
    LOG.error(String.format("Error retrieving '%s' from zip.", fileName), e);
  }
}

代码示例来源:origin: apache/incubator-atlas

private void updateGuidZipEntryMap() throws IOException {
  ZipInputStream zipInputStream = new ZipInputStream(inputStream);
  ZipEntry zipEntry = zipInputStream.getNextEntry();
  while (zipEntry != null) {
    String entryName = zipEntry.getName().replace(".json", "");
    if (guidEntityJsonMap.containsKey(entryName)) continue;
    byte[] buf = new byte[1024];
    int n = 0;
    ByteArrayOutputStream bos = new ByteArrayOutputStream();
    while ((n = zipInputStream.read(buf, 0, 1024)) > -1) {
      bos.write(buf, 0, n);
    }
    guidEntityJsonMap.put(entryName, bos.toString());
    zipEntry = zipInputStream.getNextEntry();
  }
  zipInputStream.close();
}

代码示例来源:origin: org.apache.atlas/atlas-repository

private void saveToZip(ZipExportFileNames fileName, String jsonData) throws AtlasBaseException {
  saveToZip(fileName.toString(), jsonData);
}

代码示例来源:origin: org.apache.atlas/atlas-repository

private void setCreationOrder() {
  String fileName = ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString();
  try {
    String s = getFromCache(fileName);
    this.creationOrder = convertFromJson(List.class, s);
    this.iterator = this.creationOrder.iterator();
  } catch (AtlasBaseException e) {
    LOG.error(String.format("Error retrieving '%s' from zip.", fileName), e);
  }
}

代码示例来源:origin: org.apache.atlas/atlas-repository

public AtlasTypesDef getTypesDef() throws AtlasBaseException {
  final String fileName = ZipExportFileNames.ATLAS_TYPESDEF_NAME.toString();
  String s = (String) getFromCache(fileName);
  return convertFromJson(AtlasTypesDef.class, s);
}

代码示例来源:origin: apache/incubator-atlas

private void saveToZip(String fileName, String jsonData) throws AtlasBaseException {
  try {
    addToZipStream(fileName.toString() + ".json", jsonData);
  } catch (IOException e) {
    throw new AtlasBaseException(String.format("Error writing file %s.", fileName), e);
  }
}

代码示例来源:origin: org.apache.atlas/atlas-repository

public AtlasExportResult getExportResult() throws AtlasBaseException {
  final String fileName = ZipExportFileNames.ATLAS_EXPORT_INFO_NAME.toString();
  String s = getFromCache(fileName);
  return convertFromJson(AtlasExportResult.class, s);
}

代码示例来源:origin: org.apache.atlas/atlas-repository

@Test
public void verifyExportOrderEntryName_verifies() throws AtlasBaseException, IOException {
  ZipInputStream zis = getZipInputStreamForDefaultExportOrder();
  ZipEntry ze = zis.getNextEntry();
  assertEquals(ze.getName().replace(".json", ""), ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString());
}

代码示例来源:origin: apache/incubator-atlas

@Test
public void zipWithExactlyTwoEntries_ContentsVerified() throws AtlasBaseException, IOException {
  ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
  useZipSinkToCreateEntries(byteOutputStream);
  ByteArrayInputStream bis = new ByteArrayInputStream(byteOutputStream.toByteArray());
  ZipInputStream zipStream = new ZipInputStream(bis);
  ZipEntry entry = zipStream.getNextEntry();
  assertEquals(getZipEntryAsStream(zipStream), "[\"a\",\"b\",\"c\",\"d\"]");
  assertEquals(entry.getName().replace(".json", ""), ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString());
  entry = zipStream.getNextEntry();
  assertEquals(entry.getName().replace(".json", ""), ZipExportFileNames.ATLAS_EXPORT_INFO_NAME.toString());
  assertTrue(compareJsonWithObject(getZipEntryAsStream(zipStream), defaultExportResult));
}

代码示例来源:origin: org.apache.atlas/atlas-repository

@Test
public void zipWithExactlyTwoEntries_ContentsVerified() throws AtlasBaseException, IOException {
  ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
  useZipSinkToCreateEntries(byteOutputStream);
  ByteArrayInputStream bis = new ByteArrayInputStream(byteOutputStream.toByteArray());
  ZipInputStream zipStream = new ZipInputStream(bis);
  ZipEntry entry = zipStream.getNextEntry();
  assertEquals(getZipEntryAsStream(zipStream), "[\"a\",\"b\",\"c\",\"d\"]");
  assertEquals(entry.getName().replace(".json", ""), ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString());
  entry = zipStream.getNextEntry();
  assertEquals(entry.getName().replace(".json", ""), ZipExportFileNames.ATLAS_EXPORT_INFO_NAME.toString());
  assertTrue(compareJsonWithObject(getZipEntryAsStream(zipStream), defaultExportResult));
}

代码示例来源:origin: org.apache.atlas/atlas-repository

@Test
public void recordsDoesNotRecordEntityEntries() throws AtlasBaseException {
  initZipSinkWithExportOrder();
  assertNotNull(zipSink);
  assertFalse(zipSink.hasEntity(ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString()));
}

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com