@NotThreadSafe
public class RegionManagerImpl implements RegionManager
{
private static final Logger LOGGER = LoggerFactory.getLogger( RegionManagerImpl.class );
private static final Set<OperatorType> REBALANCEABLE_REGION_TYPES = EnumSet.of( PARTITIONED_STATEFUL, STATELESS );
<BUG>private final JokerConfig config;
private final PartitionService partitionService;</BUG>
private final OperatorKVStoreManager operatorKvStoreManager;
private final OperatorTupleQueueManager operatorTupleQueueManager;
private final PipelineTransformer pipelineTransformer;

@NotThreadSafe
public class RegionManagerImpl implements RegionManager
{
private static final Logger LOGGER = LoggerFactory.getLogger( RegionManagerImpl.class );
private static final Set<OperatorType> REBALANCEABLE_REGION_TYPES = EnumSet.of( PARTITIONED_STATEFUL, STATELESS );
private final JokerConfig config;
private final Class<Supplier<TuplesImpl>> lastOperatorOutputSupplierClass;
private final PartitionService partitionService;
private final OperatorKVStoreManager operatorKvStoreManager;
private final OperatorTupleQueueManager operatorTupleQueueManager;
private final PipelineTransformer pipelineTransformer;
