test_class.file: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/reader/AbstractReaderTest.java
test_class.identifier: AbstractReaderTest
test_case.body: @Test
  	public void testEndOfPartitionEvent() throws Exception {
  		final AbstractReader reader = new MockReader(createInputGate(1));
  
  		assertTrue(reader.handleEvent(EndOfPartitionEvent.INSTANCE));
  	}
test_case.class_method_signature: AbstractReaderTest.testEndOfPartitionEvent()
test_case.full_signature: @Test public void testEndOfPartitionEvent()
test_case.identifier: testEndOfPartitionEvent
test_case.invocations: createInputGate assertTrue handleEvent
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testEndOfPartitionEvent()
focal_class.declarator: inputGate
focal_class.modifier: protected final
focal_class.original_string: protected final InputGate inputGate;
focal_class.type: InputGate
focal_class.var_name: inputGate
focal_class.declarator: taskEventHandler = new TaskEventHandler()
focal_class.modifier: private final
focal_class.original_string: private final TaskEventHandler taskEventHandler = new TaskEventHandler();
focal_class.type: TaskEventHandler
focal_class.var_name: taskEventHandler
focal_class.declarator: isIterative
focal_class.modifier: private
focal_class.original_string: private boolean isIterative;
focal_class.type: boolean
focal_class.var_name: isIterative
focal_class.declarator: currentNumberOfEndOfSuperstepEvents
focal_class.modifier: private
focal_class.original_string: private int currentNumberOfEndOfSuperstepEvents;
focal_class.type: int
focal_class.var_name: currentNumberOfEndOfSuperstepEvents
focal_class.file: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractReader.java
focal_class.identifier: AbstractReader
focal_class.interfaces: implements ReaderBase
focal_class.class_method_signature: AbstractReader.AbstractReader(InputGate inputGate)
focal_class.full_signature: protected  AbstractReader(InputGate inputGate)
focal_class.identifier: AbstractReader
focal_class.modifiers: protected
focal_class.parameters: (InputGate inputGate)
focal_class.signature:  AbstractReader(InputGate inputGate)
focal_class.class_method_signature: AbstractReader.isFinished()
focal_class.full_signature: @Override public boolean isFinished()
focal_class.identifier: isFinished
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isFinished()
focal_class.class_method_signature: AbstractReader.registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
focal_class.full_signature: @Override public void registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
focal_class.identifier: registerTaskEventListener
focal_class.modifiers: @Override public
focal_class.parameters: (EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
focal_class.return: void
focal_class.signature: void registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
focal_class.class_method_signature: AbstractReader.sendTaskEvent(TaskEvent event)
focal_class.full_signature: @Override public void sendTaskEvent(TaskEvent event)
focal_class.identifier: sendTaskEvent
focal_class.modifiers: @Override public
focal_class.parameters: (TaskEvent event)
focal_class.return: void
focal_class.signature: void sendTaskEvent(TaskEvent event)
focal_class.class_method_signature: AbstractReader.handleEvent(AbstractEvent event)
focal_class.full_signature: protected boolean handleEvent(AbstractEvent event)
focal_class.identifier: handleEvent
focal_class.modifiers: protected
focal_class.parameters: (AbstractEvent event)
focal_class.return: boolean
focal_class.signature: boolean handleEvent(AbstractEvent event)
focal_class.class_method_signature: AbstractReader.publish(TaskEvent event)
focal_class.full_signature: public void publish(TaskEvent event)
focal_class.identifier: publish
focal_class.modifiers: public
focal_class.parameters: (TaskEvent event)
focal_class.return: void
focal_class.signature: void publish(TaskEvent event)
focal_class.class_method_signature: AbstractReader.setIterativeReader()
focal_class.full_signature: @Override public void setIterativeReader()
focal_class.identifier: setIterativeReader
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void setIterativeReader()
focal_class.class_method_signature: AbstractReader.startNextSuperstep()
focal_class.full_signature: @Override public void startNextSuperstep()
focal_class.identifier: startNextSuperstep
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void startNextSuperstep()
focal_class.class_method_signature: AbstractReader.hasReachedEndOfSuperstep()
focal_class.full_signature: @Override public boolean hasReachedEndOfSuperstep()
focal_class.identifier: hasReachedEndOfSuperstep
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasReachedEndOfSuperstep()
focal_class.class_method_signature: AbstractReader.incrementEndOfSuperstepEventAndCheck()
focal_class.full_signature: private boolean incrementEndOfSuperstepEventAndCheck()
focal_class.identifier: incrementEndOfSuperstepEventAndCheck
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean incrementEndOfSuperstepEventAndCheck()
focal_method.body: protected boolean handleEvent(AbstractEvent event) throws IOException {
  		final Class<?> eventType = event.getClass();
  
  		try {
  			// ------------------------------------------------------------
  			// Runtime events
  			// ------------------------------------------------------------
  
  			// This event is also checked at the (single) input gate to release the respective
  			// channel, at which it was received.
  			if (eventType == EndOfPartitionEvent.class) {
  				return true;
  			}
  			else if (eventType == EndOfSuperstepEvent.class) {
  				return incrementEndOfSuperstepEventAndCheck();
  			}
  
  			// ------------------------------------------------------------
  			// Task events (user)
  			// ------------------------------------------------------------
  			else if (event instanceof TaskEvent) {
  				taskEventHandler.publish((TaskEvent) event);
  
  				return false;
  			}
  			else {
  				throw new IllegalStateException("Received unexpected event of type " + eventType + " at reader.");
  			}
  		}
  		catch (Throwable t) {
  			throw new IOException("Error while handling event of type " + eventType + ": " + t.getMessage(), t);
  		}
  	}
focal_method.class_method_signature: AbstractReader.handleEvent(AbstractEvent event)
focal_method.full_signature: protected boolean handleEvent(AbstractEvent event)
focal_method.identifier: handleEvent
focal_method.invocations: getClass incrementEndOfSuperstepEventAndCheck publish getMessage
focal_method.modifiers: protected
focal_method.parameters: (AbstractEvent event)
focal_method.return: boolean
focal_method.signature: boolean handleEvent(AbstractEvent event)