throw new RuntimeException(
"Cannot instantiate Distinct operator from StormSourceJoin! There are two Bolts processing operators!");
// since we don't know how data is scattered across StormSrcStorage,
// we cannot do customStreamGrouping from the previous level
_joiner = new StormSrcJoin(_firstParent, _secondParent, this, allCompNames,
_firstStorage, _secondStorage, _firstPreAggProj, _secondPreAggProj,
hierarchyPosition, builder, killer, conf);
} else
throw new RuntimeException("Unsupported ordering " + partitioningType);