abdullah alamoudi has uploaded a new patch set (#2). Change subject: Control Number of Readers for LocalFS Data ......................................................................
Control Number of Readers for LocalFS Data The number of readers is determined by the number of I/O devices. Moreover, in this change, we make feed loggers shared among node partitions. Change-Id: Ib9d5ece656220d5f562cc385f882c5ddfd3283a6 --- M asterix-app/src/main/java/org/apache/asterix/app/external/FeedOperations.java M asterix-app/src/main/java/org/apache/asterix/file/DataverseOperations.java M asterix-app/src/test/resources/runtimets/testsuite.xml M asterix-external-data/src/main/java/org/apache/asterix/external/adapter/factory/GenericAdapterFactory.java M asterix-external-data/src/main/java/org/apache/asterix/external/api/AsterixInputStream.java M asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordReader.java A asterix-external-data/src/main/java/org/apache/asterix/external/api/IStreamNotificationHandler.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/ChangeFeedDataFlowController.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/ChangeFeedWithMetaDataFlowController.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedWithMetaDataFlowController.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/converter/CSVToRecordWithMetadataAndPKConverter.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/AbstractStreamRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/LineRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/QuotedLineRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/AsterixInputStreamReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/LocalFSInputStream.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/LocalFSInputStreamFactory.java M asterix-external-data/src/main/java/org/apache/asterix/external/provider/DataflowControllerProvider.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedUtils.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/NodeResolver.java M asterix-external-data/src/test/java/org/apache/asterix/external/classad/test/ClassAdToADMTest.java M asterix-external-data/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapterFactory.java M asterix-external-data/src/test/java/org/apache/asterix/external/parser/test/RecordWithMetaTest.java M asterix-om/src/main/java/org/apache/asterix/om/util/AsterixRuntimeUtil.java 27 files changed, 470 insertions(+), 362 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/76/776/2 -- To view, visit https://asterix-gerrit.ics.uci.edu/776 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newpatchset Gerrit-Change-Id: Ib9d5ece656220d5f562cc385f882c5ddfd3283a6 Gerrit-PatchSet: 2 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]>
