Revert "[FLINK-17118][python] Add Cython support for primitive data t…

…ypes (apache#11718)" This reverts commit 1a5b35b.
spotify · Apr 17, 2020 · 9f113e4 · 9f113e4
1 parent 5421071
commit 9f113e4
Show file tree

Hide file tree

Showing 10 changed files with 5 additions and 934 deletions.
diff --git a/.gitignore b/.gitignore
@@ -36,8 +36,6 @@ flink-python/dev/.conda/
 flink-python/dev/log/
 flink-python/dev/.stage.txt
 flink-python/.eggs/
-flink-python/**/*.c
-flink-python/**/*.so
 atlassian-ide-plugin.xml
 out/
 /docs/api

diff --git a/flink-python/MANIFEST.in b/flink-python/MANIFEST.in
@@ -30,5 +30,3 @@ include pyflink/LICENSE
 include pyflink/NOTICE
 include pyflink/README.txt
 recursive-exclude deps/opt/python *
-recursive-include pyflink/fn_execution *.pxd
-recursive-include pyflink/fn_execution *.pyx
diff --git a/flink-python/pyflink/fn_execution/coder_impl.py b/flink-python/pyflink/fn_execution/coder_impl.py
@@ -237,7 +237,7 @@ def decode_from_stream(self, in_stream, nested):
  return struct.unpack('b', in_stream.read(1))[0]
 
 
-class SmallIntCoderImpl(StreamCoderImpl):
+class SmallIntImpl(StreamCoderImpl):
 
  def encode_to_stream(self, value, out_stream, nested):
  out_stream.write(struct.pack('>h', value))

diff --git a/flink-python/pyflink/fn_execution/coders.py b/flink-python/pyflink/fn_execution/coders.py
@@ -262,7 +262,7 @@ class SmallIntCoder(DeterministicCoder):
  """
 
  def _create_impl(self):
- return coder_impl.SmallIntCoderImpl()
+ return coder_impl.SmallIntImpl()
 
  def to_type_hint(self):
  return int

diff --git a/flink-python/pyflink/fn_execution/fast_coder_impl.pxd b/flink-python/pyflink/fn_execution/fast_coder_impl.pxd