class RecordWriter implements AvailabilityProvider {

	@Override
	public CompletableFuture<?> getAvailableFuture() {
		return targetPartition.getAvailableFuture();
	}

	  RecordWriter(ResultPartitionWriter writer, long timeout, String taskName);

}