<commit_before>package eu.stratosphere.nephele.checkpointing;

import eu.stratosphere.nephele.io.channels.ChannelID;
import eu.stratosphere.nephele.io.channels.ChannelType;
import eu.stratosphere.nephele.jobgraph.JobID;
import eu.stratosphere.nephele.taskmanager.bytebuffered.AbstractOutputChannelContext;
import eu.stratosphere.nephele.taskmanager.bytebuffered.IncomingEventQueue;
import eu.stratosphere.nephele.taskmanager.bytebuffered.OutputChannelContext;
import eu.stratosphere.nephele.taskmanager.transferenvelope.TransferEnvelope;

public final class ReplayOutputChannelContext extends AbstractOutputChannelContext implements OutputChannelContext {

	private final JobID jobID;

	private final ChannelID channelID;

	private final OutputChannelContext encapsulatedContext;

	ReplayOutputChannelContext(final JobID jobID, final ChannelID channelID,
			final IncomingEventQueue incomingEventQueue, final OutputChannelContext encapsulatedContext) {
		super(incomingEventQueue);

		this.jobID = jobID;
		this.channelID = channelID;
		this.encapsulatedContext = encapsulatedContext;
	}

	/**
	 * {@inheritDoc}
	 */
	@Override
	public boolean isInputChannel() {

		return true;
	}

	/**
	 * {@inheritDoc}
	 */
	@Override
	public JobID getJobID() {

		return this.jobID;
	}

	/**
	 * {@inheritDoc}
	 */
	@Override
	public ChannelID getChannelID() {

		return this.channelID;
	}

	@Override
	public ChannelID getConnectedChannelID() {
		// TODO Auto-generated method stub
		return null;
	}

	@Override<commit_msg>Fixed bug in class ReplayOutputChannelContext<commit_after>package eu.stratosphere.nephele.checkpointing;

import eu.stratosphere.nephele.io.channels.ChannelID;
import eu.stratosphere.nephele.io.channels.ChannelType;
import eu.stratosphere.nephele.jobgraph.JobID;
import eu.stratosphere.nephele.taskmanager.bytebuffered.AbstractOutputChannelContext;
import eu.stratosphere.nephele.taskmanager.bytebuffered.IncomingEventQueue;
import eu.stratosphere.nephele.taskmanager.bytebuffered.OutputChannelContext;
import eu.stratosphere.nephele.taskmanager.transferenvelope.TransferEnvelope;

public final class ReplayOutputChannelContext extends AbstractOutputChannelContext implements OutputChannelContext {

	private final JobID jobID;

	private final ChannelID channelID;

	private final OutputChannelContext encapsulatedContext;

	ReplayOutputChannelContext(final JobID jobID, final ChannelID channelID,
			final IncomingEventQueue incomingEventQueue, final OutputChannelContext encapsulatedContext) {
		super(incomingEventQueue);

		this.jobID = jobID;
		this.channelID = channelID;
		this.encapsulatedContext = encapsulatedContext;
	}

	/**
	 * {@inheritDoc}
	 */
	@Override
	public boolean isInputChannel() {

		return false;
	}

	/**
	 * {@inheritDoc}
	 */
	@Override
	public JobID getJobID() {

		return this.jobID;
	}

	/**
	 * {@inheritDoc}
	 */
	@Override
	public ChannelID getChannelID() {

		return this.channelID;
	}

	@Override
	public ChannelID getConnectedChannelID() {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
{'fraction_non_alphanumeric': 0.08374223094537128, 'fraction_numerical': 0.0, 'mean_word_length': 5.576344086021505, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5634092', 'n_tokens_mistral': 989, 'n_tokens_neox': 894, 'n_words': 177}