container/src/main/java/com/streamsets/datacollector/bundles/SupportBundleManager.java
public SupportBundle generateNewBundleFromInstances(
    List<BundleContentGenerator> generators,
    BundleType bundleType
  ) throws IOException {
    PipedInputStream inputStream = new PipedInputStream();
    PipedOutputStream outputStream = new PipedOutputStream();
    inputStream.connect(outputStream);
    ZipOutputStream zipOutputStream = new ZipOutputStream(outputStream);

    executor.submit(() -> generateNewBundleInternal(generators, bundleType, zipOutputStream));

    String bundleName = generateBundleName(bundleType);
    String bundleKey = generateBundleDate(bundleType) + "/" + bundleName;

    return new SupportBundle(
      bundleKey,
      bundleName,
      inputStream
    );
  }
public SupportBundle generateNewBundleFromInstances(
    List<BundleContentGenerator> generators,
    BundleType bundleType
  ) throws IOException {
    PipedInputStream inputStream = new PipedInputStream();
    PipedOutputStream outputStream = new PipedOutputStream();
    inputStream.connect(outputStream);
    ZipOutputStream zipOutputStream = new ZipOutputStream(outputStream);

    executor.submit(() -> generateNewBundleInternal(generators, bundleType, zipOutputStream));

    String bundleName = generateBundleName(bundleType);
    String bundleKey = generateBundleDate(bundleType) + "/" + bundleName;

    return new SupportBundle(
      bundleKey,
      bundleName,
      inputStream
    );
  }
public SupportBundle generateNewBundleFromInstances ( List < BundleContentGenerator > generators , BundleType bundleType ) throws IOException { PipedInputStream inputStream = new PipedInputStream ( ) ; PipedOutputStream outputStream = new PipedOutputStream ( ) ; inputStream . connect ( outputStream ) ; ZipOutputStream zipOutputStream = new ZipOutputStream ( outputStream ) ; executor . submit ( ( ) -> generateNewBundleInternal ( generators , bundleType , zipOutputStream ) ) ; String bundleName = generateBundleName ( bundleType ) ; String bundleKey = generateBundleDate ( bundleType ) + "/" + bundleName ; return new SupportBundle ( bundleKey , bundleName , inputStream ) ; }
Return InputStream from which a new generated resource bundle can be retrieved.
Return InputStream from which a new generated resource bundle can be retrieved .