This is an automated email from the ASF dual-hosted git repository.
liyang pushed a change to branch sync
in repository https://gitbox.apache.org/repos/asf/kylin.git.
from f50120a minor, fix query handling right outer join case
new 3222de2 KYLIN-3311 refactor Resource.checkAndPutResourceImpl() to
throw WriteConflictException
new 190f466 minor, add null case.
new 25b4b3b KYLIN-3277 Kylin should override hiveconf settings when
connecting to hive using jdbc
new 2e58857 KYLIN-3277 Code review
new 35009d4 KYLIN-3324 fix NegativeArraySizeException in
CreateDictionaryJob$2.getDictionary()
new 4d4915b minor, add test util SetAndUnsetSystemProp
new 54bdae6 KYLIN-3315 allow each project to set its own source
new f48984b KYLIN-3315 allow each project to set its own source
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../test/java/org/apache/kylin/job/DeployUtil.java | 4 +-
.../org/apache/kylin/common/KylinConfigBase.java | 2 +-
.../common/persistence/FileResourceStore.java | 6 +-
.../common/persistence/HDFSResourceStore.java | 4 +-
.../kylin/common/persistence/ResourceStore.java | 12 +-
...eException.java => WriteConflictException.java} | 9 +-
.../apache/kylin/common/util/HiveCmdBuilder.java | 54 +-------
.../kylin/common/util/HiveConfigurationUtil.java | 100 +++++++++++++
.../common/persistence/ResourceStoreTest.java | 2 +-
.../common/util/HiveConfigurationUtilTest.java | 26 ++--
.../kylin/common/util/SetAndUnsetSystemProp.java} | 24 ++--
.../java/org/apache/kylin/cube/CubeManager.java | 7 +-
.../org/apache/kylin/dict/lookup/SnapshotCLI.java | 4 +-
.../kylin/metadata/TableMetadataManager.java | 4 +-
.../kylin/metadata/TempStatementManager.java | 3 +-
.../kylin/metadata/model/ExternalFilterDesc.java | 21 ++-
.../apache/kylin/metadata/model/ISourceAware.java | 4 +
.../org/apache/kylin/metadata/model/TableDesc.java | 13 +-
.../kylin/metadata/project/ProjectInstance.java | 7 +-
.../main/java/org/apache/kylin/source/ISource.java | 8 +-
.../org/apache/kylin/source/SourceFactory.java | 62 ---------
.../org/apache/kylin/source/SourceManager.java | 154 +++++++++++++++++++++
.../java/org/apache/kylin/engine/mr/MRUtil.java | 10 +-
.../kylin/engine/mr/common/JobRelatedMetaUtil.java | 4 +-
.../kylin/engine/mr/steps/CreateDictionaryJob.java | 6 +-
.../engine/mr/steps/FactDistinctColumnsJob.java | 3 +-
.../mr/steps/FactDistinctColumnsReducer.java | 3 +-
.../kylin/engine/mr/steps/UHCDictionaryJob.java | 4 +-
.../engine/mr/steps/UHCDictionaryReducer.java | 3 +-
.../kylin/provision/BuildCubeWithStream.java | 4 +-
.../org/apache/kylin/source/SourceManagerTest.java | 61 ++++++++
.../source/hive/ITHiveSourceTableLoaderTest.java | 4 +-
.../kylin/source/hive/ITSnapshotManagerTest.java | 4 +-
.../source/jdbc/ITJdbcSourceTableLoaderTest.java | 9 +-
.../kylin/source/jdbc/ITJdbcTableReaderTest.java | 5 +
.../kylin/query/schema/OLAPSchemaFactory.java | 25 ++--
.../org/apache/kylin/query/util/PushDownUtil.java | 3 +-
.../kylin/rest/controller/TableController.java | 8 +-
.../apache/kylin/rest/job/StorageCleanupJob.java | 4 +-
.../org/apache/kylin/rest/service/AclService.java | 3 +-
.../org/apache/kylin/rest/service/JobService.java | 4 +-
.../apache/kylin/rest/service/TableService.java | 55 ++++----
.../org/apache/kylin/rest/util/AclUtilTest.java | 12 ++
.../kylin/source/hive/BeelineHiveClient.java | 15 +-
.../org/apache/kylin/source/hive/HiveSource.java | 12 +-
.../org/apache/kylin/source/jdbc/JdbcSource.java | 11 +-
.../org/apache/kylin/source/kafka/KafkaSource.java | 47 +++++--
.../kylin/storage/hbase/HBaseConnection.java | 3 +-
.../kylin/storage/hbase/HBaseResourceStore.java | 3 +-
.../tool/metrics/systemcube/KylinTableCreator.java | 15 +-
50 files changed, 587 insertions(+), 283 deletions(-)
rename
core-common/src/main/java/org/apache/kylin/common/persistence/{StorageException.java
=> WriteConflictException.java} (84%)
create mode 100644
core-common/src/main/java/org/apache/kylin/common/util/HiveConfigurationUtil.java
copy core-job/src/test/java/org/apache/kylin/job/BasicLocalMetaTest.java =>
core-common/src/test/java/org/apache/kylin/common/util/HiveConfigurationUtilTest.java
(60%)
copy core-common/src/{main/java/org/apache/kylin/common/util/FIFOIterable.java
=> test/java/org/apache/kylin/common/util/SetAndUnsetSystemProp.java} (73%)
delete mode 100644
core-metadata/src/main/java/org/apache/kylin/source/SourceFactory.java
create mode 100644
core-metadata/src/main/java/org/apache/kylin/source/SourceManager.java
create mode 100644
kylin-it/src/test/java/org/apache/kylin/source/SourceManagerTest.java
--
To stop receiving notification emails like this one, please contact
[email protected].
