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

ZipSink介绍

暂无

代码示例

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

private void initZipSinkWithExportOrder() throws AtlasBaseException {
  zipSink = new ZipSink(byteArrayOutputStream);
  zipSink.setExportOrder(defaultExportOrder);
  zipSink.close();
}

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

private void updateSinkWithOperationMetrics(ExportContext context, AtlasExportResult.OperationStatus[] statuses, int duration) throws AtlasBaseException {
  context.result.getData().getEntityCreationOrder().addAll(context.lineageProcessed);
  context.sink.setExportOrder(context.result.getData().getEntityCreationOrder());
  context.sink.setTypesDef(context.result.getData().getTypesDef());
  clearContextData(context);
  context.result.setOperationStatus(getOverallOperationStatus(statuses));
  context.result.incrementMeticsCounter("duration", duration);
  context.sink.setResult(context.result);
}

代码示例来源：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 void setTypesDef(AtlasTypesDef typesDef) throws AtlasBaseException {
  String jsonData = convertToJSON(typesDef);
  saveToZip(ZipExportFileNames.ATLAS_TYPESDEF_NAME, jsonData);
}

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

public void add(AtlasEntity entity) throws AtlasBaseException {
  String jsonData = convertToJSON(entity);
  saveToZip(entity.getGuid(), jsonData);
  recordAddedEntityGuids(entity);
}

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

@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();
}

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

private void useZipSinkToCreateEntries(ByteArrayOutputStream byteOutputStream) throws AtlasBaseException {
  ZipSink zs = new ZipSink(byteOutputStream);
  zs.setExportOrder(defaultExportOrder);
  zs.setResult(getDefaultExportResult());
  zs.close();
}

代码示例来源：origin: apache/atlas

exportSink = new ZipSink(httpServletResponse.getOutputStream());
AtlasExportResult result = exportService.run(exportSink, request, Servlets.getUserName(httpServletRequest),
                       Servlets.getHostName(httpServletRequest),
                       AtlasAuthorizationUtils.getRequestIpAddress(httpServletRequest));
exportSink.close();
  exportSink.close();

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

private void useZipSinkToCreateEntries(ByteArrayOutputStream byteOutputStream) throws AtlasBaseException {
  ZipSink zs = new ZipSink(byteOutputStream);
  zs.setExportOrder(defaultExportOrder);
  zs.setResult(getDefaultExportResult());
  zs.close();
}

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

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();
}

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

@Test
public void requestingEntityNotFound_NoData() throws AtlasBaseException, IOException {
  String requestingIP = "1.0.0.0";
  String hostName = "root";
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  ZipSink zipSink = new ZipSink(baos);
  AtlasExportResult result = exportService.run(
      zipSink, getRequestForFullFetch(), "admin", hostName, requestingIP);
  Assert.assertNull(result.getData());
  ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());
  ZipSource zipSource = new ZipSource(bais);
  assertNotNull(exportService);
  assertNotNull(zipSource.getCreationOrder());
  Assert.assertFalse(zipSource.hasNext());
}

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

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

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

private ZipSource runExportWithParameters(AtlasExportRequest request) throws AtlasBaseException, IOException {
  final String requestingIP = "1.0.0.0";
  final String hostName = "localhost";
  final String userName = "admin";
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  ZipSink zipSink = new ZipSink(baos);
  AtlasExportResult result = exportService.run(zipSink, request, userName, hostName, requestingIP);
  zipSink.close();
  ByteArrayInputStream bis = new ByteArrayInputStream(baos.toByteArray());
  ZipSource zipSource = new ZipSource(bis);
  return zipSource;
}

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

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

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

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

@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();
}

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

public void add(AtlasEntity entity) throws AtlasBaseException {
  String jsonData = convertToJSON(entity);
  saveToZip(entity.getGuid(), jsonData);
  recordAddedEntityGuids(entity);
}

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

private ZipSource runExportWithParameters(AtlasExportRequest request) throws AtlasBaseException, IOException {
  final String requestingIP = "1.0.0.0";
  final String hostName = "localhost";
  final String userName = "admin";
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  ZipSink zipSink = new ZipSink(baos);
  AtlasExportResult result = exportService.run(zipSink, request, userName, hostName, requestingIP);
  zipSink.close();
  ByteArrayInputStream bis = new ByteArrayInputStream(baos.toByteArray());
  ZipSource zipSource = new ZipSource(bis);
  return zipSource;
}

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

public void setExportOrder(List<String> result) throws AtlasBaseException {
  String jsonData = convertToJSON(result);
  saveToZip(ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME, jsonData);
}

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

@Test
public void exportType() throws AtlasBaseException {
  String requestingIP = "1.0.0.0";
  String hostName = "root";
  AtlasExportRequest request = getRequestForFullFetch();
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  ZipSink zipSink = new ZipSink(baos);
  AtlasExportResult result = exportService.run(zipSink, request, "admin", hostName, requestingIP);
  assertNotNull(exportService);
  assertEquals(result.getHostName(), hostName);
  assertEquals(result.getClientIpAddress(), requestingIP);
  assertEquals(request, result.getRequest());
}