test_class.file: flink-java/src/test/java/org/apache/flink/api/java/io/CollectionInputFormatTest.java
test_class.identifier: CollectionInputFormatTest
test_case.body: @Test
  	public void testSerializationFailure() {
  		try {
  			// a mock serializer that fails when writing
  			CollectionInputFormat<ElementType> inFormat = new CollectionInputFormat<ElementType>(
  					Collections.singleton(new ElementType()), new TestSerializer(false, true));
  			
  			ByteArrayOutputStream buffer = new ByteArrayOutputStream();
  			ObjectOutputStream out = new ObjectOutputStream(buffer);
  			
  			try {
  				out.writeObject(inFormat);
  				fail("should throw an exception");
  			}
  			catch (TestException e) {
  				// expected
  			}
  			catch (Exception e) {
  				fail("Exception not properly forwarded");
  			}
  		}
  		catch (Exception e) {
  			e.printStackTrace();
  			fail(e.getMessage());
  		}
  	}
test_case.class_method_signature: CollectionInputFormatTest.testSerializationFailure()
test_case.full_signature: @Test public void testSerializationFailure()
test_case.identifier: testSerializationFailure
test_case.invocations: singleton writeObject fail fail printStackTrace fail getMessage
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSerializationFailure()
focal_class.declarator: serialVersionUID = 1L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = 1L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: serializer
focal_class.modifier: private
focal_class.original_string: private TypeSerializer<T> serializer;
focal_class.type: TypeSerializer<T>
focal_class.var_name: serializer
focal_class.declarator: dataSet
focal_class.modifier: private transient
focal_class.original_string: private transient Collection<T> dataSet;
focal_class.type: Collection<T>
focal_class.var_name: dataSet
focal_class.declarator: iterator
focal_class.modifier: private transient
focal_class.original_string: private transient Iterator<T> iterator;
focal_class.type: Iterator<T>
focal_class.var_name: iterator
focal_class.file: flink-java/src/main/java/org/apache/flink/api/java/io/CollectionInputFormat.java
focal_class.identifier: CollectionInputFormat
focal_class.interfaces: implements NonParallelInput
focal_class.class_method_signature: CollectionInputFormat.CollectionInputFormat(Collection<T> dataSet, TypeSerializer<T> serializer)
focal_class.full_signature: public  CollectionInputFormat(Collection<T> dataSet, TypeSerializer<T> serializer)
focal_class.identifier: CollectionInputFormat
focal_class.modifiers: public
focal_class.parameters: (Collection<T> dataSet, TypeSerializer<T> serializer)
focal_class.signature:  CollectionInputFormat(Collection<T> dataSet, TypeSerializer<T> serializer)
focal_class.class_method_signature: CollectionInputFormat.reachedEnd()
focal_class.full_signature: @Override public boolean reachedEnd()
focal_class.identifier: reachedEnd
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean reachedEnd()
focal_class.class_method_signature: CollectionInputFormat.open(GenericInputSplit split)
focal_class.full_signature: @Override public void open(GenericInputSplit split)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (GenericInputSplit split)
focal_class.return: void
focal_class.signature: void open(GenericInputSplit split)
focal_class.class_method_signature: CollectionInputFormat.nextRecord(T record)
focal_class.full_signature: @Override public T nextRecord(T record)
focal_class.identifier: nextRecord
focal_class.modifiers: @Override public
focal_class.parameters: (T record)
focal_class.return: T
focal_class.signature: T nextRecord(T record)
focal_class.class_method_signature: CollectionInputFormat.writeObject(ObjectOutputStream out)
focal_class.full_signature: private void writeObject(ObjectOutputStream out)
focal_class.identifier: writeObject
focal_class.modifiers: private
focal_class.parameters: (ObjectOutputStream out)
focal_class.return: void
focal_class.signature: void writeObject(ObjectOutputStream out)
focal_class.class_method_signature: CollectionInputFormat.readObject(ObjectInputStream in)
focal_class.full_signature: private void readObject(ObjectInputStream in)
focal_class.identifier: readObject
focal_class.modifiers: private
focal_class.parameters: (ObjectInputStream in)
focal_class.return: void
focal_class.signature: void readObject(ObjectInputStream in)
focal_class.class_method_signature: CollectionInputFormat.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: CollectionInputFormat.checkCollection(Collection<X> elements, Class<X> viewedAs)
focal_class.full_signature: public static void checkCollection(Collection<X> elements, Class<X> viewedAs)
focal_class.identifier: checkCollection
focal_class.modifiers: public static
focal_class.parameters: (Collection<X> elements, Class<X> viewedAs)
focal_class.return: void
focal_class.signature: void checkCollection(Collection<X> elements, Class<X> viewedAs)
focal_class.superclass: extends GenericInputFormat<T>
focal_method.body: private void writeObject(ObjectOutputStream out) throws IOException {
  		out.defaultWriteObject();
  		
  		final int size = dataSet.size();
  		out.writeInt(size);
  		
  		if (size > 0) {
  			DataOutputViewStreamWrapper wrapper = new DataOutputViewStreamWrapper(out);
  			for (T element : dataSet){
  				serializer.serialize(element, wrapper);
  			}
  		}
  	}
focal_method.class_method_signature: CollectionInputFormat.writeObject(ObjectOutputStream out)
focal_method.full_signature: private void writeObject(ObjectOutputStream out)
focal_method.identifier: writeObject
focal_method.invocations: defaultWriteObject size writeInt serialize
focal_method.modifiers: private
focal_method.parameters: (ObjectOutputStream out)
focal_method.return: void
focal_method.signature: void writeObject(ObjectOutputStream out)