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

	public MiniBatchedWatermarkAssignerOperator(
		int rowtimeFieldIndex,
		long watermarkDelay,
		long tzOffset,
		long idleTimeout,
		long watermarkInterval) {
		this.rowtimeFieldIndex = rowtimeFieldIndex;
		this.watermarkDelay = watermarkDelay;
		this.tzOffset = tzOffset;
		this.chainingStrategy = ChainingStrategy.ALWAYS;
		this.watermarkInterval = watermarkInterval;

		this.idleTimeout = idleTimeout;
	}

	public  MiniBatchedWatermarkAssignerOperator(
		int rowtimeFieldIndex,
		long watermarkDelay,
		long tzOffset,
		long idleTimeout,
		long watermarkInterval);

}