Change in asterixdb-bad[master]: Adopt new push runtime proper fail enforcement

[abdullah alamoudi (Code Review)]

abdullah alamoudi has uploaded a new change for review.

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

Change subject: Adopt new push runtime proper fail enforcement
......................................................................

Adopt new push runtime proper fail enforcement

Change-Id: If26a8b2157f55210a972378db83d14048add03a3
---
M 
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
1 file changed, 6 insertions(+), 9 deletions(-)


  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb-bad 
refs/changes/85/1685/1

diff --git 
a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
 
b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
index c5b7ef2..7750ea8 100644
--- 
a/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
+++ 
b/asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
@@ -51,8 +51,8 @@
 
     private final ByteBufferInputStream bbis = new ByteBufferInputStream();
     private final DataInputStream di = new DataInputStream(bbis);
-    private final AOrderedListSerializerDeserializer subSerDes = new 
AOrderedListSerializerDeserializer(
-            new AOrderedListType(BuiltinType.AUUID, null));
+    private final AOrderedListSerializerDeserializer subSerDes =
+            new AOrderedListSerializerDeserializer(new 
AOrderedListType(BuiltinType.AUUID, null));
 
     private IPointable inputArg0 = new VoidPointable();
     private IPointable inputArg1 = new VoidPointable();
@@ -76,12 +76,11 @@
     }
 
     @Override
-    public void open() throws HyracksDataException {
-        return;
+    public void doOpen() throws HyracksDataException {
     }
 
     @Override
-    public void nextFrame(ByteBuffer buffer) throws HyracksDataException {
+    public void doNextFrame(ByteBuffer buffer) throws HyracksDataException {
         tAccess.reset(buffer);
         int nTuple = tAccess.getTupleCount();
         for (int t = 0; t < nTuple; t++) {
@@ -118,7 +117,6 @@
 
     @Override
     public void close() throws HyracksDataException {
-        return;
     }
 
     @Override
@@ -128,12 +126,11 @@
     }
 
     @Override
-    public void flush() throws HyracksDataException {
-        return;
+    public void doFlush() throws HyracksDataException {
     }
 
     @Override
-    public void fail() throws HyracksDataException {
+    public void doFail() throws HyracksDataException {
         failed = true;
     }
 }

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

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