Examples of ColumnType

Examples of org.apache.hadoop.zebra.schema.ColumnType

393
394
395
396
397
398
399
400
401
402
403
  }

  final public Schema.ColumnSchema AnonymousRecordSchema(Schema.ColumnSchema schema, String name, int cl, int colIndex) throws ParseException, ParseException {
        Schema.ColumnSchema fs = null, fs0 = null;
        Token t;
  ColumnType ct;
        if (schema == null)
        {
                String msg = "no matching column: " + name;
                throw new ParseException(msg);
        } else if ((ct = schema.getType()) != ColumnType.RECORD && ct != ColumnType.COLLECTION) {
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

17
18
19
20
21
22
23
24
25
26
27
                                        objout.close();
                                        System.out.println(schema.toString());
      }

  final public ColumnType Type() throws ParseException {
        ColumnType type;
    switch ((jj_ntk==-1)?jj_ntk():jj_ntk) {
    case INT:
    case BOOL:
    case LONG:
    case FLOAT:
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

44
45
46
47
48
49
50
51
52
53
54
    throw new Error("Missing return statement in function");
  }

  final public ColumnType CompositeType() throws ParseException {
        Token t = null;
        ColumnType type;
    switch ((jj_ntk==-1)?jj_ntk():jj_ntk) {
    case MAP:
      t = jj_consume_token(MAP);
      break;
    case COLLECTION:
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

67
68
69
70
71
72
73
74
75
76
77
    throw new Error("Missing return statement in function");
  }

  final public ColumnType BasicType() throws ParseException {
        Token t = null;
        ColumnType type;
    switch ((jj_ntk==-1)?jj_ntk():jj_ntk) {
    case INT:
      t = jj_consume_token(INT);
      break;
    case LONG:
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

160
161
162
163
164
165
166
167
168
169
170
    throw new Error("Missing return statement in function");
  }

  final public Schema.ColumnSchema AtomSchema() throws ParseException, ParseException {
        Token t1 = null;
        ColumnType type = ColumnType.BYTES;
        Schema.ColumnSchema fs;
    t1 = jj_consume_token(IDENTIFIER);
    switch ((jj_ntk==-1)?jj_ntk():jj_ntk) {
    case 22:
      jj_consume_token(22);
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

259
260
261
262
263
264
265
266
267
268
269
                {if (true) return fs;}
    throw new Error("Missing return statement in function");
  }

  final public Schema.ColumnSchema AnonymousAtomSchema() throws ParseException, ParseException {
        ColumnType type = ColumnType.BYTES;
        Schema.ColumnSchema fs;
    switch ((jj_ntk==-1)?jj_ntk():jj_ntk) {
    case INT:
    case BOOL:
    case LONG:
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

30
31
32
33
34
35
36
37
38
39
40
import org.apache.pig.impl.logicalLayer.schema.Schema;
import org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema;

class SchemaConverter {
    public static ColumnType toTableType(byte ptype) {
        ColumnType ret;
        switch (ptype) {
        case DataType.INTEGER:
            ret = ColumnType.INT;
            break;
        case DataType.LONG:
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
        Schema ret = new Schema();
        for (String col : tschema.getColumns()) {
            org.apache.hadoop.zebra.schema.Schema.ColumnSchema columnSchema =
                tschema.getColumn(col);
            if (columnSchema != null) {
                ColumnType ct = columnSchema.getType();
                if (ct == org.apache.hadoop.zebra.schema.ColumnType.RECORD ||
                        ct == org.apache.hadoop.zebra.schema.ColumnType.COLLECTION)
                    ret.add(new FieldSchema(col, toPigSchema(columnSchema.getSchema()), ct.pigDataType()));
                else
                    ret.add(new FieldSchema(col, ct.pigDataType()));
            } else {
                ret.add(new FieldSchema(null, null));
            }
        }
        return ret;
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

122
123
124
125
126
127
128
129
130
131
132
        org.apache.hadoop.zebra.schema.Schema schema = new org.apache.hadoop.zebra.schema.Schema();
        ResourceSchema.ResourceFieldSchema[] fields = rSchema.getFields();
        for( ResourceSchema.ResourceFieldSchema field : fields ) {
            String name = field.getName();
            ColumnType type = toTableType( field.getType() );
            org.apache.hadoop.zebra.schema.Schema cSchema = convertFromResourceSchema( field.getSchema() );
            if( type == ColumnType.MAP && cSchema == null ) {
                cSchema = new org.apache.hadoop.zebra.schema.Schema();
                cSchema.add( new org.apache.hadoop.zebra.schema.Schema.ColumnSchema( "", ColumnType.BYTES ) );
            }
View Full Code Here

Examples of org.apache.hadoop.zebra.schema.ColumnType

80
81
82
83
84
85
86
87
88
89
90
          pn.setDT(ColumnType.MAP);
        if (fs == null)
             continue; // skip non-existing field
   
        j = fs.getIndex();
        ColumnType ct = pn.getDT();
        if (ct == ColumnType.MAP || ct == ColumnType.RECORD || ct == ColumnType.COLLECTION)
        {
          // record/map subfield is expected
          sc = new SplitColumn(j, ct);
          if (ct == ColumnType.MAP)
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.