abdullah alamoudi has submitted this change and it was merged. Change subject: Add compatibility for Socket adapter ......................................................................
Add compatibility for Socket adapter This change allows the use of alias for socket adapter Change-Id: I8c8c78598c0cfea36c18503a73b002ece700be71 Reviewed-on: https://asterix-gerrit.ics.uci.edu/609 Tested-by: Jenkins <[email protected]> Reviewed-by: abdullah alamoudi <[email protected]> --- M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataCompatibilityUtils.java 1 file changed, 9 insertions(+), 0 deletions(-) Approvals: abdullah alamoudi: Looks good to me, approved Jenkins: Verified diff --git a/asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataCompatibilityUtils.java b/asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataCompatibilityUtils.java index 4e6401a..7bfe698 100644 --- a/asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataCompatibilityUtils.java +++ b/asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataCompatibilityUtils.java @@ -78,6 +78,15 @@ configuration.put(ExternalDataConstants.KEY_READER_STREAM, ExternalDataConstants.ALIAS_LOCALFS_ADAPTER); } + // Socket + if (adapterName.equalsIgnoreCase(ExternalDataConstants.ALIAS_SOCKET_ADAPTER)) { + if (configuration.get(ExternalDataConstants.KEY_FORMAT) == null) { + throw new AsterixException("Unspecified format parameter for socket adapter"); + } + configuration.put(ExternalDataConstants.KEY_READER, configuration.get(ExternalDataConstants.KEY_FORMAT)); + configuration.put(ExternalDataConstants.KEY_READER_STREAM, ExternalDataConstants.STREAM_SOCKET); + } + // Twitter (Pull) if (adapterName.equals(ExternalDataConstants.ALIAS_TWITTER_PULL_ADAPTER)) { configuration.put(ExternalDataConstants.KEY_READER, ExternalDataConstants.READER_TWITTER_PULL); -- To view, visit https://asterix-gerrit.ics.uci.edu/609 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: merged Gerrit-Change-Id: I8c8c78598c0cfea36c18503a73b002ece700be71 Gerrit-PatchSet: 3 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Jianfeng Jia <[email protected]> Gerrit-Reviewer: Till Westmann <[email protected]> Gerrit-Reviewer: abdullah alamoudi <[email protected]>
