docs: public static <T> SinkFunction.Context<T> forTimestamp(long timestamp) {
  		return new SinkFunction.Context<T>() {
  			@Override
  			public long currentProcessingTime() {
  				throw new RuntimeException("Not implemented");
  			}
  
  			@Override
  			public long currentWatermark() {
  				throw new RuntimeException("Not implemented");
  			}
  
  			@Override
  			public Long timestamp() {
  				return timestamp;
  			}
  		};
  	}