Sfoglia il codice sorgente

HPCC-13534 Fix issues following review

Signed-off-by: Gavin Halliday <gavin.halliday@lexisnexis.com>
Gavin Halliday 10 anni fa
parent
commit
64da4e1696

+ 0 - 3
testing/regress/ecl/streamread.ecl

@@ -40,8 +40,6 @@ streamed dataset(outRecord) doRead(const varstring name) := EMBED(C++ : distribu
     };
 
     #body
-    unsigned numParts = ctx->getNodes();
-    unsigned whichPart = ctx->getNodeNum();
     return new StreamCreator(ctx, _resultAllocator);
 ENDEMBED;
 
@@ -74,7 +72,6 @@ dataset(outRecord) doReadBlock(const varstring name) := EMBED(C++ : distributed)
     static const char * rows3 = "Gavin     \x01Simon     \002Charlotte \x09TheEnd    \x00";
 
     #body
-    //Can return constant allocations as roxie rows
     __lenResult = 44;
     __result = rtlMalloc(44);
     memcpy(__result, rows3, 44);

+ 1 - 2
thorlcr/activities/iterate/thiterateslave.cpp

@@ -401,7 +401,7 @@ class CStreamedIteratorSlaveActivity : public CSlaveActivity, public CThorDataLi
 {
     IHThorStreamedIteratorArg *helper;
     Owned<IRowStream> rows;
-    bool eof, isLocal;
+    bool eof;
 
 public:
     IMPLEMENT_IINTERFACE_USING(CSimpleInterface);
@@ -414,7 +414,6 @@ public:
     {
         appendOutputLinked(this);   // adding 'me' to outputs array
         helper = static_cast <IHThorStreamedIteratorArg *> (queryHelper());
-        isLocal = false;
     }
     virtual void start()
     {