private void addStream(final Path file, final FeedDoc feed) throws IOException {
        if (file.getFileName().toString().endsWith(".zip")) {
            loadZipData(file, feed);

        } else {
            // Add the associated data to the stream store.
            String streamTypeName;
            long millis;
            if (feed.isReference()) {
                streamTypeName = StreamTypeNames.RAW_REFERENCE;

                // We need to ensure the reference data is older then the earliest
                // event we are going to see. In the case of these component tests
                // we have some events from 2007.
                millis = DateUtil.parseNormalDateTimeString("2006-01-01T00:00:00.000Z");
            } else {
                streamTypeName = StreamTypeNames.RAW_EVENTS;
                millis = DateUtil.parseNormalDateTimeString("2006-04-01T00:00:00.000Z");
            }

            // Create the stream.
            final MetaProperties metaProperties = MetaProperties.builder()
                    .feedName(feed.getName())
                    .typeName(streamTypeName)
                    .createMs(millis)
                    .build();

            Meta meta;
            try (final Target target = streamStore.openTarget(metaProperties)) {
                meta = target.getMeta();
                final InputStream inputStream = new BufferedInputStream(Files.newInputStream(file));
                TargetUtil.write(target, inputStream);
            }

            // Check that what was written to the store is the same as the
            // contents of the file.
            try (final Source checkSource = streamStore.openSource(meta.getId())) {
                final byte[] original = Files.readAllBytes(file);
                final byte[] stored = SourceUtil.read(checkSource);
                assertThat(Arrays.equals(original, stored)).isTrue();
            }
        }
    }
NOTE some of the input data for this test is buried in the following zip file so you will need
to crack it open to see what is being loaded.
stroom/stroom-core/src/test/resources/samples/input/ZIP_TEST-DATA_SPLITTER-EVENTS~1.zip
stroom-app/src/test/java/stroom/pipeline/task/TranslationTest.java