diff --git a/include/clients/rt/FluidDataSetWr.hpp b/include/clients/rt/FluidDataSetWr.hpp
index 20fcf0f..1fbb006 100644
--- a/include/clients/rt/FluidDataSetWr.hpp
+++ b/include/clients/rt/FluidDataSetWr.hpp
@@ -23,18 +23,19 @@ namespace client {
 class DataSetWriterClient : public FluidBaseClient, OfflineIn, OfflineOut
 {
 public:
-  FLUID_DECLARE_PARAMS(StringParam("label", "Label"),
-                       BufferParam("buf", "Data Buffer"),
-                       DataSetClientRef::makeParam("dataSet", "DataSet Name"));
+  FLUID_DECLARE_PARAMS(
+      DataSetClientRef::makeParam("dataSet", "DataSet Name"),
+      StringParam("labelPrefix","Label Prefix"),
+      LongParam("labelOffset", "Label Counter Offset", 0),
+      BufferParam("buf", "Data Buffer")
+ );
 
   DataSetWriterClient(ParamSetViewType& p) : mParams(p) {}
 
   template <typename T>
   Result process(FluidContext&)
   {
-    auto& idx = get<0>();
-    auto  buf = get<1>();
-    auto  dataset = get<2>().get();
+    auto  dataset = get<0>().get();
     if (auto datasetPtr = dataset.lock())
     {
       std::stringstream ss;
@@ -42,7 +43,6 @@ public:
       
       index labelOffset = get<2>(); 
       if(labelOffset >=  0) ss << labelOffset +  (mCounter++);
-      
             
       auto  buf = get<3>();
       return datasetPtr->addPoint(ss.str(), buf);
@@ -50,6 +50,9 @@ public:
     else
       return {Result::Status::kError, "No dataset"};
   }
+  
+  private:
+    index mCounter{0};
 };
 
 using NRTThreadedDataSetWriter =