diff -r e11f1ad20826 -r 3e1308e7606d include/relpipe/reader/handlers/RelationalReaderBaseHandler.h
--- a/include/relpipe/reader/handlers/RelationalReaderBaseHandler.h	Mon Sep 03 23:40:12 2018 +0200
+++ b/include/relpipe/reader/handlers/RelationalReaderBaseHandler.h	Sat Sep 08 19:42:29 2018 +0200
@@ -12,10 +12,12 @@
 public:
 	virtual ~RelationalReaderBaseHadler() = default;
 
-	virtual void startRelation(string_t name, std::vector<std::pair<string_t, TypeId>> attributes) = 0;
+    virtual void startRelation(string_t name, std::vector<std::pair<string_t, TypeId>> attributes) = 0;
+
+    virtual void endOfPipe() = 0;
 
 };
 
 }
 }
-}
\ No newline at end of file
+}