class CogroupedKStreamImpl extends AbstractStream<K, VOut> implements CogroupedKStream<K, VOut> {

    @Override
    public KTable<K, VOut> aggregate(final Initializer<VOut> initializer,
                                     final Materialized<K, VOut, KeyValueStore<Bytes, byte[]>> materialized) {
        return aggregate(initializer, NamedInternal.empty(), materialized);
    }

      CogroupedKStreamImpl(final String name,
                         final Set<String> subTopologySourceNodes,
                         final StreamsGraphNode streamsGraphNode,
                         final InternalStreamsBuilder builder);

}