Package com.facebook.hiveio.common

Examples of com.facebook.hiveio.common.HiveTableName

98
99
100
101
102
103
104
105
106
107
108
    hapi.setMyProfileId(DEFAULT_PROFILE_ID);

    List<InputSplit> splits = hapi.getSplits(hiveConf, client);
    LOG.info("Have {} splits to read", splits.size());

    HiveTableName hiveTableName = new HiveTableName(opts.tableOpts.database, opts.tableOpts.table);
    HiveTableSchema schema = HiveTableSchemas.lookup(client, hiveTableName);

    Stats stats = Stats.get(hiveStats);
    Context context = new Context(hapi, hiveConf, schema, hiveStats, opts, stats);
    long startNanos = System.nanoTime();
View Full Code Here
138
139
140
141
142
143
144
  /**
   * Make hive table name from this
   * @return HiveTableName
   */
  public HiveTableName hiveTableName() {
    return new HiveTableName(dbName, tableName);
  }
View Full Code Here
89
90
91
92
93
94
95
  /**
   * Make hive table name from this
   * @return HiveTableName
   */
  public HiveTableName  hiveTableName() {
    return new HiveTableName(dbName, tableName);
  }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    hapi.setMyProfileId(DEFAULT_PROFILE_ID);

    List<InputSplit> splits = hapi.getSplits(new JobContext(hiveConf, new JobID()));
    LOG.info("Have {} splits to read", splits.size());

    HiveTableName hiveTableName = new HiveTableName(args.inputTable.database, args.inputTable.table);
    HiveTableSchema schema = HiveTableSchemas.lookup(client, hiveTableName);

    Stats stats = Stats.get(hiveStats);
    Context context = new Context(hapi, hiveConf, schema, hiveStats, stats);
    long startNanos = System.nanoTime();
View Full Code Here
52
53
54
55
56
57
58
59
60
  /**
   * Constructor
   */
  public HiveTableSchemaImpl() {
    tableName = new HiveTableName("_unknown_", "_unknown_");
    partitionPositions = Maps.newHashMap();
    columnPositions = Maps.newHashMap();
  }
View Full Code Here
92
93
94
95
96
97
98
99
    Map<String, Integer> partitionToIndex = Maps.newHashMap();
    for (String partitionName : partitionNames) {
      partitionToIndex.put(partitionName, index++);
    }

    HiveTableName hiveTableName = new HiveTableName(table.getDbName(), table.getTableName());
    return new HiveTableSchemaImpl(hiveTableName, partitionToIndex, columnToIndex);
  }
View Full Code Here
143
144
145
146
147
148
149
    Writables.readStrIntMap(in, partitionPositions);
    Writables.readStrIntMap(in, columnPositions);
    numColumns = computeNumColumns(columnPositions);
    String dbName = WritableUtils.readString(in);
    String tblName = WritableUtils.readString(in);
    tableName = new HiveTableName(dbName, tblName);
  }
View Full Code Here
144
145
146
147
148
149
150
  /**
   * Make hive table name from this
   * @return HiveTableName
   */
  public HiveTableName hiveTableName() {
    return new HiveTableName(dbName, tableName);
  }
View Full Code Here
95
96
97
98
99
100
101
  /**
   * Make hive table name from this
   * @return HiveTableName
   */
  public HiveTableName  hiveTableName() {
    return new HiveTableName(dbName, tableName);
  }
View Full Code Here
TOP

Related Classes of com.facebook.hiveio.common.HiveTableName

  • com.facebook.hiveio.input.HiveInputDescription
  • com.facebook.hiveio.output.HiveOutputDescription
  • com.facebook.hiveio.schema.HiveTableSchemaImpl
  • com.facebook.hiveio.tailer.Tailer
  • com.facebook.hiveio.tailer.TailerCmd
    • Copyright © 2018 www.massapicom. 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.