test_class.declarator: executorService = Executors.newCachedThreadPool()
test_class.modifier: private final static
test_class.original_string: private final static ExecutorService executorService = Executors.newCachedThreadPool();
test_class.type: ExecutorService
test_class.var_name: executorService
test_class.file: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java
test_class.identifier: PipelinedSubpartitionTest
test_class.superclass: extends SubpartitionTestBase
test_case.body: @Test
  	public void testIllegalReadViewRequest() throws Exception {
  		final PipelinedSubpartition subpartition = createSubpartition();
  
  		// Successful request
  		assertNotNull(subpartition.createReadView(null));
  
  		try {
  			subpartition.createReadView(null);
  
  			fail("Did not throw expected exception after duplicate read view request.");
  		}
  		catch (IllegalStateException expected) {
  		}
  	}
test_case.class_method_signature: PipelinedSubpartitionTest.testIllegalReadViewRequest()
test_case.full_signature: @Test public void testIllegalReadViewRequest()
test_case.identifier: testIllegalReadViewRequest
test_case.invocations: createSubpartition assertNotNull createReadView createReadView fail
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testIllegalReadViewRequest()
focal_class.declarator: LOG = LoggerFactory.getLogger(PipelinedSubpartition.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(PipelinedSubpartition.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: isFinished
focal_class.modifier: private
focal_class.original_string: private boolean isFinished;
focal_class.type: boolean
focal_class.var_name: isFinished
focal_class.declarator: isReleased
focal_class.modifier: private volatile
focal_class.original_string: private volatile boolean isReleased;
focal_class.type: boolean
focal_class.var_name: isReleased
focal_class.declarator: registeredListener
focal_class.modifier: private
focal_class.original_string: private NotificationListener registeredListener;
focal_class.type: NotificationListener
focal_class.var_name: registeredListener
focal_class.declarator: readView
focal_class.modifier: private
focal_class.original_string: private PipelinedSubpartitionView readView;
focal_class.type: PipelinedSubpartitionView
focal_class.var_name: readView
focal_class.declarator: buffers = new ArrayDeque<Buffer>()
focal_class.modifier: final
focal_class.original_string: final ArrayDeque<Buffer> buffers = new ArrayDeque<Buffer>();
focal_class.type: ArrayDeque<Buffer>
focal_class.var_name: buffers
focal_class.file: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
focal_class.identifier: PipelinedSubpartition
focal_class.class_method_signature: PipelinedSubpartition.PipelinedSubpartition(int index, ResultPartition parent)
focal_class.full_signature:   PipelinedSubpartition(int index, ResultPartition parent)
focal_class.identifier: PipelinedSubpartition
focal_class.parameters: (int index, ResultPartition parent)
focal_class.signature:  PipelinedSubpartition(int index, ResultPartition parent)
focal_class.class_method_signature: PipelinedSubpartition.add(Buffer buffer)
focal_class.full_signature: @Override public boolean add(Buffer buffer)
focal_class.identifier: add
focal_class.modifiers: @Override public
focal_class.parameters: (Buffer buffer)
focal_class.return: boolean
focal_class.signature: boolean add(Buffer buffer)
focal_class.class_method_signature: PipelinedSubpartition.finish()
focal_class.full_signature: @Override public void finish()
focal_class.identifier: finish
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void finish()
focal_class.class_method_signature: PipelinedSubpartition.release()
focal_class.full_signature: @Override public void release()
focal_class.identifier: release
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void release()
focal_class.class_method_signature: PipelinedSubpartition.releaseMemory()
focal_class.full_signature: @Override public int releaseMemory()
focal_class.identifier: releaseMemory
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int releaseMemory()
focal_class.class_method_signature: PipelinedSubpartition.isReleased()
focal_class.full_signature: @Override public boolean isReleased()
focal_class.identifier: isReleased
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isReleased()
focal_class.class_method_signature: PipelinedSubpartition.createReadView(BufferProvider bufferProvider)
focal_class.full_signature: @Override public PipelinedSubpartitionView createReadView(BufferProvider bufferProvider)
focal_class.identifier: createReadView
focal_class.modifiers: @Override public
focal_class.parameters: (BufferProvider bufferProvider)
focal_class.return: PipelinedSubpartitionView
focal_class.signature: PipelinedSubpartitionView createReadView(BufferProvider bufferProvider)
focal_class.class_method_signature: PipelinedSubpartition.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.class_method_signature: PipelinedSubpartition.registerListener(NotificationListener listener)
focal_class.full_signature:  boolean registerListener(NotificationListener listener)
focal_class.identifier: registerListener
focal_class.parameters: (NotificationListener listener)
focal_class.return: boolean
focal_class.signature: boolean registerListener(NotificationListener listener)
focal_class.superclass: extends ResultSubpartition
focal_method.body: @Override
  	public PipelinedSubpartitionView createReadView(BufferProvider bufferProvider) {
  		synchronized (buffers) {
  			if (readView != null) {
  				throw new IllegalStateException("Subpartition " + index + " of "
  						+ parent.getPartitionId() + " is being or already has been " +
  						"consumed, but pipelined subpartitions can only be consumed once.");
  			}
  
  			readView = new PipelinedSubpartitionView(this);
  
  			LOG.debug("Created read view for subpartition {} of partition {}.", index, parent.getPartitionId());
  
  			return readView;
  		}
  	}
focal_method.class_method_signature: PipelinedSubpartition.createReadView(BufferProvider bufferProvider)
focal_method.full_signature: @Override public PipelinedSubpartitionView createReadView(BufferProvider bufferProvider)
focal_method.identifier: createReadView
focal_method.invocations: getPartitionId debug getPartitionId
focal_method.modifiers: @Override public
focal_method.parameters: (BufferProvider bufferProvider)
focal_method.return: PipelinedSubpartitionView
focal_method.signature: PipelinedSubpartitionView createReadView(BufferProvider bufferProvider)