public static Stream createProcessedStream(final Stream parent, final Feed feed, final StreamType streamType,
                                               final StreamProcessor streamProcessor, final StreamTask streamTask) {
        final Stream stream = new Stream();

        if (parent != null) {
            if (parent.getEffectiveMs() != null) {
                stream.effectiveMs = parent.getEffectiveMs();
            } else {
                stream.effectiveMs = parent.getCreateMs();
            }
            stream.parentStreamId = parent.getId();
        }

        stream.feed = feed;
        stream.streamType = streamType;
        stream.streamProcessor = streamProcessor;
        if (streamTask != null) {
            stream.streamTaskId = streamTask.getId();
        }

        // When were we created
        stream.createMs = System.currentTimeMillis();
        // Ensure an effective time
        if (stream.effectiveMs == null) {
            stream.effectiveMs = stream.createMs;
        }

        return stream;
    }
The stream we are related to.
stroom-legacy/stroom-legacy-model_6_1/src/main/java/stroom/legacy/model_6_1/Stream.java