You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by ra...@apache.org on 2018/02/06 05:46:20 UTC
[04/50] lens git commit: LENS-1433: Virtual Fact over a fact with
single storage - multi update period is writing wrong query
LENS-1433: Virtual Fact over a fact with single storage - multi update period is writing wrong query
Project: http://git-wip-us.apache.org/repos/asf/lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/28aa4a1e
Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/28aa4a1e
Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/28aa4a1e
Branch: refs/heads/master
Commit: 28aa4a1e25121849e8ada9e0b843d525e2e1f479
Parents: d3875b4
Author: Rajitha R <ra...@gmail.com>
Authored: Wed Jun 14 15:06:56 2017 +0530
Committer: rajub <ra...@lazada.com>
Committed: Mon Jun 19 09:04:45 2017 +0800
----------------------------------------------------------------------
.../java/org/apache/lens/cube/parse/StorageCandidate.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lens/blob/28aa4a1e/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java
----------------------------------------------------------------------
diff --git a/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java b/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java
index c8ff3b8..6e5aa4c 100644
--- a/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java
+++ b/lens-cube/src/main/java/org/apache/lens/cube/parse/StorageCandidate.java
@@ -265,7 +265,7 @@ public class StorageCandidate implements Candidate, CandidateTable {
Set<String> uniqueStorageTables = new HashSet<>();
for (UpdatePeriod updatePeriod : validUpdatePeriods) {
uniqueStorageTables.add(
- getCubeMetastoreClient().getStorageTableName(fact.getName(), storageName, updatePeriod)
+ getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(), storageName, updatePeriod)
);
}
return uniqueStorageTables;
@@ -891,7 +891,7 @@ public class StorageCandidate implements Candidate, CandidateTable {
return this.startTime;
}
return getCubeMetastoreClient().getStorageTableStartDate(
- getCubeMetastoreClient().getStorageTableName(fact.getName(), storageName, interval), fact.getName());
+ getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(), storageName, interval), fact.getName());
}
private Date getStorageTableEndDate(UpdatePeriod interval) throws LensException {
@@ -900,7 +900,7 @@ public class StorageCandidate implements Candidate, CandidateTable {
return this.endTime;
}
return getCubeMetastoreClient().getStorageTableEndDate(
- getCubeMetastoreClient().getStorageTableName(fact.getName(), storageName, interval), fact.getName());
+ getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(), storageName, interval), fact.getName());
}
@@ -931,7 +931,7 @@ public class StorageCandidate implements Candidate, CandidateTable {
StorageCandidate updatePeriodSpecificSc;
for (UpdatePeriod period : participatingUpdatePeriods) {
updatePeriodSpecificSc = copy();
- updatePeriodSpecificSc.setResolvedName(getCubeMetastoreClient().getStorageTableName(fact.getName(),
+ updatePeriodSpecificSc.setResolvedName(getCubeMetastoreClient().getStorageTableName(fact.getSourceFactName(),
storageName, period));
updatePeriodSpecificSc.truncatePartitions(period);
periodSpecificScList.add(updatePeriodSpecificSc);