Author: pradeepkth Date: Fri Dec 4 23:38:35 2009 New Revision: 887455 URL: http://svn.apache.org/viewvc?rev=887455&view=rev Log: Commiting a file missed in previous commit for PIG-1090
Added: hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestResourceSchema.java Added: hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestResourceSchema.java URL: http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestResourceSchema.java?rev=887455&view=auto ============================================================================== --- hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestResourceSchema.java (added) +++ hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestResourceSchema.java Fri Dec 4 23:38:35 2009 @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.pig.test; + +import junit.framework.TestCase; + +import org.apache.pig.ResourceSchema; +import org.apache.pig.backend.executionengine.ExecException; +import org.apache.pig.data.DataType; +import org.apache.pig.impl.logicalLayer.FrontendException; +import org.apache.pig.impl.logicalLayer.schema.Schema; +import org.apache.pig.impl.logicalLayer.schema.SchemaMergeException; +import org.apache.pig.test.utils.TypeCheckingTestUtil; +import org.junit.Test; + +public class TestResourceSchema extends TestCase { + + /** + * Test that ResourceSchema is correctly created given a + * pig.Schema and vice versa + * @throws FrontendException + * @throws SchemaMergeException + * @throws ExecException + */ + @Test + public void testResourceFlatSchemaCreation() throws ExecException, SchemaMergeException, FrontendException { + String [] aliases ={"f1", "f2"}; + byte[] types = {DataType.CHARARRAY, DataType.INTEGER}; + Schema origSchema = TypeCheckingTestUtil.genFlatSchema( + aliases,types); + ResourceSchema rsSchema = new ResourceSchema(origSchema); + assertEquals("num fields", aliases.length, rsSchema.fields.length); + ResourceSchema.ResourceFieldSchema[] fields = rsSchema.fields; + for (int i=0; i<fields.length; i++) { + assertEquals(fields[i].name, aliases[i]); + assertEquals(fields[i].type, types[i]); + } + Schema genSchema = Schema.getPigSchema(rsSchema); + assertTrue("generated schema equals original" , Schema.equals(genSchema, origSchema, true, false)); + } + + +} \ No newline at end of file