if( flowElement instanceof PartitionTap ) // todo: generify
configBuilder.groupSplits( false );
DataSourceDescriptor dataSourceDescriptor = configBuilder.build();
vertex.addDataSource( FlowElements.id( flowElement ), dataSourceDescriptor );
}
for( FlowElement flowElement : sinkConfigs.keySet() )
{
if( !( flowElement instanceof Tap ) )