feat: add mapt sdk support

[KeranYang]

This change adds the mapt sdk support such that numaflow source vertex can use it to perform initial transformations on input data. Transformations include 1. filtering on source messages and 2. assigning a new event time to each of the messages, etc.

This change has been tested by https://github.com/numaproj/numaflow/pull/588

[codecov[bot]]

Codecov Report

Merging #64 (cf18e85) into main (ea78057) will increase coverage by 0.52%. The diff coverage is 100.00%.

@@            Coverage Diff             @@
##             main      #64      +/-   ##
==========================================
+ Coverage   96.23%   96.75%   +0.52%     
==========================================
  Files          10       10              
  Lines         345      401      +56     
  Branches       27       32       +5     
==========================================
+ Hits          332      388      +56     
  Misses          8        8              
  Partials        5        5              

Impacted Files	Coverage Δ
pynumaflow/function/__init__.py	100.00% <ø> (ø)
pynumaflow/function/_dtypes.py	99.30% <100.00%> (+0.22%)	:arrow_up:
pynumaflow/function/server.py	93.27% <100.00%> (+1.44%)	:arrow_up:

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more