You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by br...@apache.org on 2014/09/08 06:38:26 UTC
svn commit: r1623263 [9/28] - in /hive/branches/spark: ./
accumulo-handler/src/java/org/apache/hadoop/hive/accumulo/predicate/
ant/src/org/apache/hadoop/hive/ant/ beeline/src/java/org/apache/hive/beeline/
beeline/src/test/org/apache/hive/beeline/ bin/ ...
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java?rev=1623263&r1=1623262&r2=1623263&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java Mon Sep 8 04:38:17 2014
@@ -350,14 +350,14 @@ public class SetPartitionsStatsRequest i
case 1: // COL_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list252 = iprot.readListBegin();
- struct.colStats = new ArrayList<ColumnStatistics>(_list252.size);
- for (int _i253 = 0; _i253 < _list252.size; ++_i253)
+ org.apache.thrift.protocol.TList _list286 = iprot.readListBegin();
+ struct.colStats = new ArrayList<ColumnStatistics>(_list286.size);
+ for (int _i287 = 0; _i287 < _list286.size; ++_i287)
{
- ColumnStatistics _elem254; // required
- _elem254 = new ColumnStatistics();
- _elem254.read(iprot);
- struct.colStats.add(_elem254);
+ ColumnStatistics _elem288; // required
+ _elem288 = new ColumnStatistics();
+ _elem288.read(iprot);
+ struct.colStats.add(_elem288);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class SetPartitionsStatsRequest i
oprot.writeFieldBegin(COL_STATS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.colStats.size()));
- for (ColumnStatistics _iter255 : struct.colStats)
+ for (ColumnStatistics _iter289 : struct.colStats)
{
- _iter255.write(oprot);
+ _iter289.write(oprot);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class SetPartitionsStatsRequest i
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.colStats.size());
- for (ColumnStatistics _iter256 : struct.colStats)
+ for (ColumnStatistics _iter290 : struct.colStats)
{
- _iter256.write(oprot);
+ _iter290.write(oprot);
}
}
}
@@ -421,14 +421,14 @@ public class SetPartitionsStatsRequest i
public void read(org.apache.thrift.protocol.TProtocol prot, SetPartitionsStatsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list257 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.colStats = new ArrayList<ColumnStatistics>(_list257.size);
- for (int _i258 = 0; _i258 < _list257.size; ++_i258)
+ org.apache.thrift.protocol.TList _list291 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.colStats = new ArrayList<ColumnStatistics>(_list291.size);
+ for (int _i292 = 0; _i292 < _list291.size; ++_i292)
{
- ColumnStatistics _elem259; // required
- _elem259 = new ColumnStatistics();
- _elem259.read(iprot);
- struct.colStats.add(_elem259);
+ ColumnStatistics _elem293; // required
+ _elem293 = new ColumnStatistics();
+ _elem293.read(iprot);
+ struct.colStats.add(_elem293);
}
}
struct.setColStatsIsSet(true);
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java?rev=1623263&r1=1623262&r2=1623263&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java Mon Sep 8 04:38:17 2014
@@ -350,14 +350,14 @@ public class ShowCompactResponse impleme
case 1: // COMPACTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list450 = iprot.readListBegin();
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list450.size);
- for (int _i451 = 0; _i451 < _list450.size; ++_i451)
+ org.apache.thrift.protocol.TList _list484 = iprot.readListBegin();
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list484.size);
+ for (int _i485 = 0; _i485 < _list484.size; ++_i485)
{
- ShowCompactResponseElement _elem452; // required
- _elem452 = new ShowCompactResponseElement();
- _elem452.read(iprot);
- struct.compacts.add(_elem452);
+ ShowCompactResponseElement _elem486; // required
+ _elem486 = new ShowCompactResponseElement();
+ _elem486.read(iprot);
+ struct.compacts.add(_elem486);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class ShowCompactResponse impleme
oprot.writeFieldBegin(COMPACTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size()));
- for (ShowCompactResponseElement _iter453 : struct.compacts)
+ for (ShowCompactResponseElement _iter487 : struct.compacts)
{
- _iter453.write(oprot);
+ _iter487.write(oprot);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class ShowCompactResponse impleme
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.compacts.size());
- for (ShowCompactResponseElement _iter454 : struct.compacts)
+ for (ShowCompactResponseElement _iter488 : struct.compacts)
{
- _iter454.write(oprot);
+ _iter488.write(oprot);
}
}
}
@@ -421,14 +421,14 @@ public class ShowCompactResponse impleme
public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list455 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list455.size);
- for (int _i456 = 0; _i456 < _list455.size; ++_i456)
+ org.apache.thrift.protocol.TList _list489 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list489.size);
+ for (int _i490 = 0; _i490 < _list489.size; ++_i490)
{
- ShowCompactResponseElement _elem457; // required
- _elem457 = new ShowCompactResponseElement();
- _elem457.read(iprot);
- struct.compacts.add(_elem457);
+ ShowCompactResponseElement _elem491; // required
+ _elem491 = new ShowCompactResponseElement();
+ _elem491.read(iprot);
+ struct.compacts.add(_elem491);
}
}
struct.setCompactsIsSet(true);
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java?rev=1623263&r1=1623262&r2=1623263&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java Mon Sep 8 04:38:17 2014
@@ -346,14 +346,14 @@ public class ShowLocksResponse implement
case 1: // LOCKS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list426 = iprot.readListBegin();
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list426.size);
- for (int _i427 = 0; _i427 < _list426.size; ++_i427)
+ org.apache.thrift.protocol.TList _list460 = iprot.readListBegin();
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list460.size);
+ for (int _i461 = 0; _i461 < _list460.size; ++_i461)
{
- ShowLocksResponseElement _elem428; // required
- _elem428 = new ShowLocksResponseElement();
- _elem428.read(iprot);
- struct.locks.add(_elem428);
+ ShowLocksResponseElement _elem462; // required
+ _elem462 = new ShowLocksResponseElement();
+ _elem462.read(iprot);
+ struct.locks.add(_elem462);
}
iprot.readListEnd();
}
@@ -379,9 +379,9 @@ public class ShowLocksResponse implement
oprot.writeFieldBegin(LOCKS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.locks.size()));
- for (ShowLocksResponseElement _iter429 : struct.locks)
+ for (ShowLocksResponseElement _iter463 : struct.locks)
{
- _iter429.write(oprot);
+ _iter463.write(oprot);
}
oprot.writeListEnd();
}
@@ -412,9 +412,9 @@ public class ShowLocksResponse implement
if (struct.isSetLocks()) {
{
oprot.writeI32(struct.locks.size());
- for (ShowLocksResponseElement _iter430 : struct.locks)
+ for (ShowLocksResponseElement _iter464 : struct.locks)
{
- _iter430.write(oprot);
+ _iter464.write(oprot);
}
}
}
@@ -426,14 +426,14 @@ public class ShowLocksResponse implement
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list431 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list431.size);
- for (int _i432 = 0; _i432 < _list431.size; ++_i432)
+ org.apache.thrift.protocol.TList _list465 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list465.size);
+ for (int _i466 = 0; _i466 < _list465.size; ++_i466)
{
- ShowLocksResponseElement _elem433; // required
- _elem433 = new ShowLocksResponseElement();
- _elem433.read(iprot);
- struct.locks.add(_elem433);
+ ShowLocksResponseElement _elem467; // required
+ _elem467 = new ShowLocksResponseElement();
+ _elem467.read(iprot);
+ struct.locks.add(_elem467);
}
}
struct.setLocksIsSet(true);
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java?rev=1623263&r1=1623262&r2=1623263&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java Mon Sep 8 04:38:17 2014
@@ -216,17 +216,17 @@ public class StorageDescriptor implement
{
this();
this.cols = cols;
- this.location = location;
- this.inputFormat = inputFormat;
- this.outputFormat = outputFormat;
+ this.location = org.apache.hive.common.util.HiveStringUtils.intern(location);
+ this.inputFormat = org.apache.hive.common.util.HiveStringUtils.intern(inputFormat);
+ this.outputFormat = org.apache.hive.common.util.HiveStringUtils.intern(outputFormat);
this.compressed = compressed;
setCompressedIsSet(true);
this.numBuckets = numBuckets;
setNumBucketsIsSet(true);
this.serdeInfo = serdeInfo;
- this.bucketCols = bucketCols;
+ this.bucketCols = org.apache.hive.common.util.HiveStringUtils.intern(bucketCols);
this.sortCols = sortCols;
- this.parameters = parameters;
+ this.parameters = org.apache.hive.common.util.HiveStringUtils.intern(parameters);
}
/**
@@ -242,13 +242,13 @@ public class StorageDescriptor implement
this.cols = __this__cols;
}
if (other.isSetLocation()) {
- this.location = other.location;
+ this.location = org.apache.hive.common.util.HiveStringUtils.intern(other.location);
}
if (other.isSetInputFormat()) {
- this.inputFormat = other.inputFormat;
+ this.inputFormat = org.apache.hive.common.util.HiveStringUtils.intern(other.inputFormat);
}
if (other.isSetOutputFormat()) {
- this.outputFormat = other.outputFormat;
+ this.outputFormat = org.apache.hive.common.util.HiveStringUtils.intern(other.outputFormat);
}
this.compressed = other.compressed;
this.numBuckets = other.numBuckets;
@@ -276,9 +276,9 @@ public class StorageDescriptor implement
String other_element_key = other_element.getKey();
String other_element_value = other_element.getValue();
- String __this__parameters_copy_key = other_element_key;
+ String __this__parameters_copy_key = org.apache.hive.common.util.HiveStringUtils.intern(other_element_key);
- String __this__parameters_copy_value = other_element_value;
+ String __this__parameters_copy_value = org.apache.hive.common.util.HiveStringUtils.intern(other_element_value);
__this__parameters.put(__this__parameters_copy_key, __this__parameters_copy_value);
}
@@ -356,7 +356,7 @@ public class StorageDescriptor implement
}
public void setLocation(String location) {
- this.location = location;
+ this.location = org.apache.hive.common.util.HiveStringUtils.intern(location);
}
public void unsetLocation() {
@@ -379,7 +379,7 @@ public class StorageDescriptor implement
}
public void setInputFormat(String inputFormat) {
- this.inputFormat = inputFormat;
+ this.inputFormat = org.apache.hive.common.util.HiveStringUtils.intern(inputFormat);
}
public void unsetInputFormat() {
@@ -402,7 +402,7 @@ public class StorageDescriptor implement
}
public void setOutputFormat(String outputFormat) {
- this.outputFormat = outputFormat;
+ this.outputFormat = org.apache.hive.common.util.HiveStringUtils.intern(outputFormat);
}
public void unsetOutputFormat() {
@@ -507,7 +507,7 @@ public class StorageDescriptor implement
}
public void setBucketCols(List<String> bucketCols) {
- this.bucketCols = bucketCols;
+ this.bucketCols = org.apache.hive.common.util.HiveStringUtils.intern(bucketCols);
}
public void unsetBucketCols() {
@@ -579,7 +579,7 @@ public class StorageDescriptor implement
}
public void setParameters(Map<String,String> parameters) {
- this.parameters = parameters;
+ this.parameters = org.apache.hive.common.util.HiveStringUtils.intern(parameters);
}
public void unsetParameters() {
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java?rev=1623263&r1=1623262&r2=1623263&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java Mon Sep 8 04:38:17 2014
@@ -536,13 +536,13 @@ public class TableStatsRequest implement
case 3: // COL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list322 = iprot.readListBegin();
- struct.colNames = new ArrayList<String>(_list322.size);
- for (int _i323 = 0; _i323 < _list322.size; ++_i323)
+ org.apache.thrift.protocol.TList _list356 = iprot.readListBegin();
+ struct.colNames = new ArrayList<String>(_list356.size);
+ for (int _i357 = 0; _i357 < _list356.size; ++_i357)
{
- String _elem324; // required
- _elem324 = iprot.readString();
- struct.colNames.add(_elem324);
+ String _elem358; // required
+ _elem358 = iprot.readString();
+ struct.colNames.add(_elem358);
}
iprot.readListEnd();
}
@@ -578,9 +578,9 @@ public class TableStatsRequest implement
oprot.writeFieldBegin(COL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.colNames.size()));
- for (String _iter325 : struct.colNames)
+ for (String _iter359 : struct.colNames)
{
- oprot.writeString(_iter325);
+ oprot.writeString(_iter359);
}
oprot.writeListEnd();
}
@@ -607,9 +607,9 @@ public class TableStatsRequest implement
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.colNames.size());
- for (String _iter326 : struct.colNames)
+ for (String _iter360 : struct.colNames)
{
- oprot.writeString(_iter326);
+ oprot.writeString(_iter360);
}
}
}
@@ -622,13 +622,13 @@ public class TableStatsRequest implement
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TList _list327 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.colNames = new ArrayList<String>(_list327.size);
- for (int _i328 = 0; _i328 < _list327.size; ++_i328)
+ org.apache.thrift.protocol.TList _list361 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.colNames = new ArrayList<String>(_list361.size);
+ for (int _i362 = 0; _i362 < _list361.size; ++_i362)
{
- String _elem329; // required
- _elem329 = iprot.readString();
- struct.colNames.add(_elem329);
+ String _elem363; // required
+ _elem363 = iprot.readString();
+ struct.colNames.add(_elem363);
}
}
struct.setColNamesIsSet(true);
Modified: hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java?rev=1623263&r1=1623262&r2=1623263&view=diff
==============================================================================
--- hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java (original)
+++ hive/branches/spark/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java Mon Sep 8 04:38:17 2014
@@ -350,14 +350,14 @@ public class TableStatsResult implements
case 1: // TABLE_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list296 = iprot.readListBegin();
- struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list296.size);
- for (int _i297 = 0; _i297 < _list296.size; ++_i297)
+ org.apache.thrift.protocol.TList _list330 = iprot.readListBegin();
+ struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list330.size);
+ for (int _i331 = 0; _i331 < _list330.size; ++_i331)
{
- ColumnStatisticsObj _elem298; // required
- _elem298 = new ColumnStatisticsObj();
- _elem298.read(iprot);
- struct.tableStats.add(_elem298);
+ ColumnStatisticsObj _elem332; // required
+ _elem332 = new ColumnStatisticsObj();
+ _elem332.read(iprot);
+ struct.tableStats.add(_elem332);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ public class TableStatsResult implements
oprot.writeFieldBegin(TABLE_STATS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tableStats.size()));
- for (ColumnStatisticsObj _iter299 : struct.tableStats)
+ for (ColumnStatisticsObj _iter333 : struct.tableStats)
{
- _iter299.write(oprot);
+ _iter333.write(oprot);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ public class TableStatsResult implements
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tableStats.size());
- for (ColumnStatisticsObj _iter300 : struct.tableStats)
+ for (ColumnStatisticsObj _iter334 : struct.tableStats)
{
- _iter300.write(oprot);
+ _iter334.write(oprot);
}
}
}
@@ -421,14 +421,14 @@ public class TableStatsResult implements
public void read(org.apache.thrift.protocol.TProtocol prot, TableStatsResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list301 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list301.size);
- for (int _i302 = 0; _i302 < _list301.size; ++_i302)
+ org.apache.thrift.protocol.TList _list335 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list335.size);
+ for (int _i336 = 0; _i336 < _list335.size; ++_i336)
{
- ColumnStatisticsObj _elem303; // required
- _elem303 = new ColumnStatisticsObj();
- _elem303.read(iprot);
- struct.tableStats.add(_elem303);
+ ColumnStatisticsObj _elem337; // required
+ _elem337 = new ColumnStatisticsObj();
+ _elem337.read(iprot);
+ struct.tableStats.add(_elem337);
}
}
struct.setTableStatsIsSet(true);