Cascalog operation redesign

gistfile1.clj

(defaggregateop my-aggregator
  {:params [a b c]
  :prepare true}
  [flow-process]
   (let []
    (aggregator 
      (init []
        )
      (aggregate [state field1 field2]
        )
      (complete [state]
        )
      (cleanup []
        ))))

(defaggregateop my-aggregator2
  {:params [a b c]}
  (init []
    )
  (aggregate [state field1 field2]
    )
  (complete [state]
    ))

(defbufferop my-buffer [tuples]
  )

(deffilterop my-filter
  {:params [a b c]
  :prepare true}
  [flow-process]
   (let []
    (operation 
      (execute [field1 field2]
        )
      (cleanup []
        ))))

(deffilterop my-filter2 {:params [a b c]}
  [field1 field2]
    )

(def op (my-filter2 1 2 3))


(deffilterop my-filter3 [field1 field2]
    )