abdullah alamoudi has uploaded a new patch set (#2). Change subject: Support Sending Messages Alongside Frame Data ......................................................................
Support Sending Messages Alongside Frame Data This change support sending messages with records. The tuple Appender reserves 100 bytes for a message. Before sending the frame, it appends The message in the last tuple position. The message is read from the task context as the shared object between different operators in the pipeline. The first use of this feature will be within feeds to request acks for at least once semantics. Change-Id: Iaa23e9f8a909ddcafc1c3ee95181092eb04ee1ad --- M asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java M asterix-common/src/main/java/org/apache/asterix/common/parse/ITupleForwarder.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/CounterTimerTupleForwarder.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedTupleForwarder.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FrameFullTupleForwarder.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RateControlledTupleForwarder.java M asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java M asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java M asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java M asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java M asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java A asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedMessageUtils.java M asterix-external-data/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapterFactory.java 13 files changed, 81 insertions(+), 19 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/05/605/2 -- To view, visit https://asterix-gerrit.ics.uci.edu/605 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newpatchset Gerrit-Change-Id: Iaa23e9f8a909ddcafc1c3ee95181092eb04ee1ad Gerrit-PatchSet: 2 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]>
