You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by am...@apache.org on 2016/04/30 00:30:30 UTC
incubator-asterixdb git commit: Enable Fully Qualified Class Names
for Adapter Data Sources
Repository: incubator-asterixdb
Updated Branches:
refs/heads/master 6fa914e03 -> 8b3412cb8
Enable Fully Qualified Class Names for Adapter Data Sources
Change-Id: I49953d4570b828b7cecb2ec926e017d008b13ddc
Reviewed-on: https://asterix-gerrit.ics.uci.edu/837
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Reviewed-by: Murtadha Hubail <hu...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/commit/8b3412cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/tree/8b3412cb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/diff/8b3412cb
Branch: refs/heads/master
Commit: 8b3412cb88c7d3da865c6a778b35c0340c0d22a6
Parents: 6fa914e
Author: Abdullah Alamoudi <ba...@gmail.com>
Authored: Fri Apr 29 14:32:27 2016 +0300
Committer: abdullah alamoudi <ba...@gmail.com>
Committed: Fri Apr 29 10:06:01 2016 -0700
----------------------------------------------------------------------
.../external/provider/DatasourceFactoryProvider.java | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/8b3412cb/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
index 0f24f91..0954fca 100644
--- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
+++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
@@ -74,7 +74,11 @@ public class DatasourceFactoryProvider {
streamSourceFactory = new TwitterFirehoseStreamFactory();
break;
default:
- throw new AsterixException("unknown input stream factory");
+ try {
+ streamSourceFactory = (IInputStreamFactory) Class.forName(streamSource).newInstance();
+ } catch (Exception e) {
+ throw new AsterixException("unknown input stream factory: " + streamSource, e);
+ }
}
}
return streamSourceFactory;
@@ -109,7 +113,11 @@ public class DatasourceFactoryProvider {
case ExternalDataConstants.STREAM_SOCKET_CLIENT:
return new StreamRecordReaderFactory(new SocketClientInputStreamFactory());
default:
- throw new AsterixException("unknown record reader factory: " + reader);
+ try {
+ return (IRecordReaderFactory<?>) Class.forName(reader).newInstance();
+ } catch (Exception e) {
+ throw new AsterixException("unknown record reader factory: " + reader, e);
+ }
}
}
}