Change in asterixdb[master]: Enable Fully Qualified Class Names for Adapter Data Sources

[abdullah alamoudi (Code Review)]

abdullah alamoudi has uploaded a new change for review.

  https://asterix-gerrit.ics.uci.edu/837

Change subject: Enable Fully Qualified Class Names for Adapter Data Sources
......................................................................

Enable Fully Qualified Class Names for Adapter Data Sources

Change-Id: I49953d4570b828b7cecb2ec926e017d008b13ddc
---
M 
asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
1 file changed, 10 insertions(+), 2 deletions(-)


  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb 
refs/changes/37/837/1

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 @@
                     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 @@
             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);
+                }
         }
     }
 }

-- 
To view, visit https://asterix-gerrit.ics.uci.edu/837
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: I49953d4570b828b7cecb2ec926e017d008b13ddc
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <bamou...@gmail.com>