Examples of ColumnSchema


Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

        System.out.println("--------------------------------");
      }
      CGSchema cgs1 = cgschemas[0];
      CGSchema cgs2 = cgschemas[1];

      ColumnSchema f11 = cgs1.getSchema().getColumn(0);
      Assert.assertEquals("r1.f1", f11.getName());
      Assert.assertEquals(ColumnType.INT, f11.getType());
      ColumnSchema f12 = cgs1.getSchema().getColumn(1);
      Assert.assertEquals("r2.r3.f3", f12.getName());
      Assert.assertEquals(ColumnType.FLOAT, f12.getType());

      ColumnSchema f21 = cgs2.getSchema().getColumn(0);
      Assert.assertEquals("r1.f2", f21.getName());
      Assert.assertEquals(ColumnType.INT, f21.getType());
      ColumnSchema f22 = cgs2.getSchema().getColumn(1);
      Assert.assertEquals("r2.r3.f4", f22.getName());
      Assert.assertEquals(ColumnType.BYTES, f22.getType());

      System.out.println("*********** Column Map **********");
      Map<String, HashSet<Partition.PartitionInfo.ColumnMappingEntry>> colmap = p
          .getPartitionInfo().getColMap();
      Assert.assertEquals(colmap.size(), 5);
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

    parser = new TableSchemaParser(new StringReader(strSch));
    schema = parser.RecordSchema(null);
    System.out.println(schema);

    ColumnSchema f2 = schema.getColumn(1);
    Assert.assertEquals("f2", f2.getName());
    Assert.assertEquals(ColumnType.LONG, f2.getType());
  }
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

    parser = new TableSchemaParser(new StringReader(strSch));
    schema = parser.RecordSchema(null);
    System.out.println(schema);

    ColumnSchema f2 = schema.getColumn(1);
    Assert.assertEquals("f2", f2.getName());
    Assert.assertEquals(ColumnType.BYTES, f2.getType());

    ColumnSchema f4 = schema.getColumn(3);
    Assert.assertEquals("f4", f4.getName());
    Assert.assertEquals(ColumnType.BYTES, f4.getType());
   
    ColumnSchema f6 = schema.getColumn(5);
    Assert.assertEquals("f6::f61", f6.getName());
    Assert.assertEquals(ColumnType.BYTES, f6.getType());
   
    ColumnSchema f7 = schema.getColumn(6);
    Assert.assertEquals("f7::f71", f7.getName());
    Assert.assertEquals(ColumnType.MAP, f7.getType());
  }
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

        System.out.println("--------------------------------");
      }
      CGSchema cgs1 = cgschemas[0];
      CGSchema cgs2 = cgschemas[1];

      ColumnSchema f11 = cgs1.getSchema().getColumn(0);
      Assert.assertEquals("c1", f11.getName());
      Assert.assertEquals(ColumnType.COLLECTION, f11.getType());
      ColumnSchema f21 = cgs2.getSchema().getColumn(0);
      Assert.assertEquals("c2", f21.getName());
      Assert.assertEquals(ColumnType.COLLECTION, f21.getType());

      System.out.println("*********** Column Map **********");
      Map<String, HashSet<Partition.PartitionInfo.ColumnMappingEntry>> colmap = p
          .getPartitionInfo().getColMap();
      Assert.assertEquals(colmap.size(), 2);
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

        System.out.println("--------------------------------");
      }
      CGSchema cgs1 = cgschemas[0];
      CGSchema cgs2 = cgschemas[1];

      ColumnSchema f11 = cgs1.getSchema().getColumn(0);
      Assert.assertEquals("c1.f1", f11.getName());
      Assert.assertEquals(ColumnType.INT, f11.getType());
      ColumnSchema f21 = cgs2.getSchema().getColumn(0);
      Assert.assertEquals("c1.f2", f21.getName());
      Assert.assertEquals(ColumnType.INT, f21.getType());
      ColumnSchema f22 = cgs2.getSchema().getColumn(1);
      Assert.assertEquals("c2", f22.getName());
      Assert.assertEquals(ColumnType.COLLECTION, f22.getType());

      System.out.println("*********** Column Map **********");
      Map<String, HashSet<Partition.PartitionInfo.ColumnMappingEntry>> colmap = p
          .getPartitionInfo().getColMap();
      Assert.assertEquals(colmap.size(), 3);
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

    parser = new TableSchemaParser(new StringReader(strSch));
    schema = parser.RecordSchema(null);
    System.out.println(schema);

    // test 1st level schema;
    ColumnSchema f1 = schema.getColumn(0);
    Assert.assertEquals("f1", f1.getName());
    Assert.assertEquals(ColumnType.INT, f1.getType());

    ColumnSchema f2 = schema.getColumn(1);
    Assert.assertEquals("m1", f2.getName());
    Assert.assertEquals(ColumnType.MAP, f2.getType());
   
    Schema temp = f2.getSchema();
    System.out.println(temp.getNumColumns());
    ColumnSchema cs = temp.getColumn(0);
    System.out.println(cs.getType());
   
  }
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

    parser = new TableSchemaParser(new StringReader(strSch));
    schema = parser.RecordSchema(null);
    System.out.println(schema);

    // test 1st level schema;
    ColumnSchema f1 = schema.getColumn(0);
    Assert.assertEquals("f1", f1.getName());
    Assert.assertEquals(ColumnType.INT, f1.getType());

    ColumnSchema f2 = schema.getColumn(1);
    Assert.assertEquals("m1", f2.getName());
    Assert.assertEquals(ColumnType.MAP, f2.getType());

    // test 2nd level schema;
    Schema f2Schema = f2.getSchema();
    ColumnSchema f21 = f2Schema.getColumn(0);
    // Assert.assertEquals("m1", f2.getName());
    Assert.assertEquals(ColumnType.MAP, f21.getType());

    // test 3rd level schema;
    Schema f21Schema = f21.getSchema();
    ColumnSchema f211 = f21Schema.getColumn(0);
    // Assert.assertEquals("m1", f2.getName());
    Assert.assertEquals(ColumnType.FLOAT, f211.getType());
  }
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

    parser = new TableSchemaParser(new StringReader(strSch));
    schema = parser.RecordSchema(null);
    System.out.println(schema);

    // test 1st level schema;
    ColumnSchema f1 = schema.getColumn(0);
    Assert.assertEquals("m1", f1.getName());
    Assert.assertEquals(ColumnType.MAP, f1.getType());

    ColumnSchema f2 = schema.getColumn(1);
    Assert.assertEquals("m2", f2.getName());
    Assert.assertEquals(ColumnType.MAP, f2.getType());

    ColumnSchema f3 = schema.getColumn(2);
    Assert.assertEquals("f3", f3.getName());
    Assert.assertEquals(ColumnType.BYTES, f3.getType());

    // test 2nd level schema;
    Schema f1Schema = f1.getSchema();
    ColumnSchema f11 = f1Schema.getColumn(0);
    Assert.assertEquals(ColumnType.MAP, f11.getType());

    Schema f2Schema = f2.getSchema();
    ColumnSchema f21 = f2Schema.getColumn(0);
    Assert.assertEquals(ColumnType.BOOL, f21.getType());

    // test 3rd level schema;
    Schema f11Schema = f11.getSchema();
    ColumnSchema f111 = f11Schema.getColumn(0);
    Assert.assertEquals(ColumnType.FLOAT, f111.getType());
  }
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

    parser = new TableSchemaParser(new StringReader(strSch));
    schema = parser.RecordSchema(null);
    System.out.println(schema);

    // test 1st level schema;
    ColumnSchema f1 = schema.getColumn(0);
    Assert.assertEquals("c1", f1.getName());
    Assert.assertEquals(ColumnType.COLLECTION, f1.getType());

    ColumnSchema f2 = schema.getColumn(1);
    Assert.assertEquals("c2", f2.getName());
    Assert.assertEquals(ColumnType.COLLECTION, f2.getType());

    // test 2nd level schema;
    Schema f1Schema = f1.getSchema();
    ColumnSchema f11 = f1Schema.getColumn(0).getSchema().getColumn(0);
    Assert.assertEquals("f1", f11.getName());
    Assert.assertEquals(ColumnType.INT, f11.getType());
    ColumnSchema f12 = f1Schema.getColumn(0).getSchema().getColumn(1);
    Assert.assertEquals("f2", f12.getName());
    Assert.assertEquals(ColumnType.INT, f12.getType());

    Schema f2Schema = f2.getSchema();
    ColumnSchema f21 = f2Schema.getColumn(0);
    Assert.assertNull(f21.getName());
    Assert.assertEquals(ColumnType.RECORD, f21.getType());

    // test 3rd level schema;
    Schema f21Schema = f21.getSchema();
    ColumnSchema f211 = f21Schema.getColumn(0);
    Assert.assertTrue(f211.getName().equals("f5"));
    Assert.assertEquals(ColumnType.COLLECTION, f211.getType());
    Schema f211Schema = f211.getSchema();
   
    ColumnSchema f212 = f211Schema.getColumn(0);
    Assert.assertNull(f212.getName());
    Assert.assertEquals(ColumnType.RECORD, f212.getType());
    Schema f212Schema = f212.getSchema();
    ColumnSchema f213 = f212Schema.getColumn(0);
    Assert.assertEquals("f3", f213.getName());
    Assert.assertEquals(ColumnType.FLOAT, f213.getType());
    ColumnSchema f214 = f212Schema.getColumn(1);
    Assert.assertEquals("f4", f214.getName());
    Assert.assertEquals(ColumnType.BYTES, f214.getType());
  }
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.Schema.ColumnSchema

  @Test
  public void testSchema() throws ParseException {
    System.out.println(schema);

    // test 1st level schema;
    ColumnSchema f1 = schema.getColumn(0);
    Assert.assertEquals("r", f1.getName());
    Assert.assertEquals(ColumnType.RECORD, f1.getType());

    // test 2nd level schema;
    Schema f1Schema = f1.getSchema();
    ColumnSchema f11 = f1Schema.getColumn(0);
    Assert.assertEquals("r", f11.getName());
    Assert.assertEquals(ColumnType.RECORD, f11.getType());
    ColumnSchema f12 = f1Schema.getColumn(1);
    Assert.assertEquals("f2", f12.getName());
    Assert.assertEquals(ColumnType.MAP, f12.getType());

    // test 3rd level schema;
    Schema f11Schema = f11.getSchema();
    ColumnSchema f111 = f11Schema.getColumn(0);
    Assert.assertEquals("f1", f111.getName());
    Assert.assertEquals(ColumnType.INT, f111.getType());
    ColumnSchema f112 = f11Schema.getColumn(1);
    Assert.assertEquals("f2", f112.getName());
    Assert.assertEquals(ColumnType.INT, f112.getType());

    Schema f12Schema = f12.getSchema();
    ColumnSchema f121 = f12Schema.getColumn(0);
    // Assert.assertEquals("", f121.getName());
    Assert.assertEquals(ColumnType.BYTES, f121.getType());
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.