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

	public WatermarkAssignerOperator(int rowtimeFieldIndex, long watermarkDelay, long idleTimeout) {
		this.rowtimeFieldIndex = rowtimeFieldIndex;
		this.watermarkDelay = watermarkDelay;

		this.idleTimeout = idleTimeout;
		this.chainingStrategy = ChainingStrategy.ALWAYS;
	}

	public  WatermarkAssignerOperator(int rowtimeFieldIndex, long watermarkDelay, long idleTimeout);

}