class MiniBatchAssignerOperator extends AbstractStreamOperator<BaseRow> implements OneInputStreamOperator<BaseRow, BaseRow>, ProcessingTimeCallback {

	public MiniBatchAssignerOperator(long intervalMs) {
		this.intervalMs = intervalMs;
		this.chainingStrategy = ChainingStrategy.ALWAYS;
	}

	public  MiniBatchAssignerOperator(long intervalMs);

}