Skip to content
This repository was archived by the owner on May 12, 2021. It is now read-only.
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
22 commits
Select commit Hold shift + click to select a range
e1675db
TAJO-1952: Implement PartitionFileFragment
blrunner May 16, 2016
ff16139
Clean up unit test codes
blrunner May 16, 2016
5022476
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo…
blrunner May 16, 2016
1f898e8
Remove unnecessary codes
blrunner May 17, 2016
af5a41c
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo…
blrunner May 18, 2016
4f3fc7a
Fix broken build
blrunner May 18, 2016
758d9c3
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo…
blrunner May 18, 2016
03ee254
Implment PartitionFileFragmentSerde and fix some bugs
blrunner May 18, 2016
c347887
Fix broadcast join bugs
blrunner May 19, 2016
3836de1
Merge branch 'TAJO-1952' of https://github.com/blrunner/tajo into TAJ…
blrunner May 19, 2016
565c525
Remove PartitionFileFragment
blrunner May 19, 2016
d0b4453
Remove unncessary modifications and apply PartitionedTableRewriter::b…
blrunner May 19, 2016
dd562c6
Fix bugs of TestFileFragment
blrunner May 20, 2016
f7224b5
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo…
blrunner May 25, 2016
87b2875
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo…
blrunner May 25, 2016
d5a9894
Use FileFragment instead of PartitionFileFragment
blrunner May 25, 2016
8ff36d9
Change Option<String> to String of partitionKeys variable type
blrunner May 25, 2016
a105990
Remove unnecessary modifications of FileFragment
blrunner May 25, 2016
54d7429
Remove unnecessary codes
blrunner May 27, 2016
812b3ec
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo…
blrunner Jul 20, 2016
b2bcdbc
Remove duplicated codes
blrunner Jul 20, 2016
836f944
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo…
blrunner Aug 29, 2016
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,11 @@ public static TableDesc newTableDesc(String tableName, Schema schema, TableMeta
return new TableDesc(tableName, schema, meta, path.toUri());
}

public static TableDesc newTableDesc(String tableName, Schema schema, TableMeta meta, Path path
, PartitionMethodDesc partitionMethodDesc) {
return new TableDesc(tableName, schema, meta, path.toUri(), partitionMethodDesc);
}

public static TableDesc newTableDesc(TableDescProto proto) {
return new TableDesc(proto);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,32 +51,46 @@ public class TableDesc implements ProtoObject<TableDescProto>, GsonObject, Clone
public TableDesc() {
}

public TableDesc(String tableName, @Nullable Schema schema, TableMeta meta, @Nullable URI uri, boolean external) {
this(tableName, schema, meta, uri, null, external);
}

public TableDesc(String tableName, @Nullable Schema schema, TableMeta meta,
@Nullable URI uri, boolean external) {
@Nullable URI uri, @Nullable PartitionMethodDesc partitionMethodDesc, boolean external) {
this.tableName = tableName;
this.schema = schema;
this.meta = meta;
this.uri = uri;
this.partitionMethodDesc = partitionMethodDesc;
this.external = external;
}

public TableDesc(String tableName, @Nullable Schema schema, TableMeta meta, @Nullable URI path) {
this(tableName, schema, meta, path, true);
this(tableName, schema, meta, path, null, true);
}


public TableDesc(String tableName, @Nullable Schema schema, TableMeta meta, @Nullable URI path,
@Nullable PartitionMethodDesc partitionMethodDesc) {
this(tableName, schema, meta, path, partitionMethodDesc, true);
}

public TableDesc(String tableName, @Nullable Schema schema, String dataFormat, KeyValueSet options,
@Nullable URI path) {
this(tableName, schema, new TableMeta(dataFormat, options), path);
}

public TableDesc(TableDescProto proto) {

public TableDesc(String tableName, @Nullable Schema schema, String dataFormat, KeyValueSet options,
@Nullable URI path, @Nullable PartitionMethodDesc partitionMethodDesc) {
this(tableName, schema, new TableMeta(dataFormat, options), path, partitionMethodDesc);
}

public TableDesc(TableDescProto proto) {
this(proto.getTableName(), proto.hasSchema() ? SchemaFactory.newV1(proto.getSchema()) : null,
new TableMeta(proto.getMeta()), proto.hasPath() ? URI.create(proto.getPath()) : null, proto.getIsExternal());
new TableMeta(proto.getMeta()), proto.hasPath() ? URI.create(proto.getPath()) : null,
proto.hasPartition() ? new PartitionMethodDesc(proto.getPartition()) : null,
proto.getIsExternal());
if(proto.hasStats()) {
this.stats = new TableStats(proto.getStats());
}
if (proto.hasPartition()) {
this.partitionMethodDesc = new PartitionMethodDesc(proto.getPartition());
}
}

Expand Down
Loading