sinkfunc et al for storing state, still need to add an actual pig operator