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

	public WatermarkAssignerOperator(
		int rowtimeFieldIndex,
		WatermarkGenerator watermarkGenerator,
		long idleTimeout,
		ProcessingTimeService processingTimeService) {

		this.rowtimeFieldIndex = rowtimeFieldIndex;
		this.watermarkGenerator = watermarkGenerator;

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

		this.processingTimeService = checkNotNull(processingTimeService);
	}

	public  WatermarkAssignerOperator(
		int rowtimeFieldIndex,
		WatermarkGenerator watermarkGenerator,
		long idleTimeout,
		ProcessingTimeService processingTimeService);

}