ARROW-1395: [C++/Python] Remove APIs deprecated from 0.5.0 onward

cpp/src/arrow/io/hdfs.h

@@ -172,8 +172,8 @@ class ARROW_EXPORT HadoopFileSystem : public FileSystem {
   DISALLOW_COPY_AND_ASSIGN(HadoopFileSystem);
 };
 
-// 0.6.0
 #ifndef ARROW_NO_DEPRECATED_API
+/// \deprecated Since 0.6.0
 using HdfsClient = HadoopFileSystem;
 #endif
 

cpp/src/arrow/ipc/reader.h

@@ -194,13 +194,6 @@ Status ARROW_EXPORT ReadRecordBatch(const std::shared_ptr<Schema>& schema, int64
 Status ARROW_EXPORT ReadTensor(int64_t offset, io::RandomAccessFile* file,
                                std::shared_ptr<Tensor>* out);
 
-/// Backwards-compatibility for Arrow < 0.4.0
-///
-#ifndef ARROW_NO_DEPRECATED_API
-using StreamReader = RecordBatchReader;
-using FileReader = RecordBatchFileReader;
-#endif
-
 }  // namespace ipc
 }  // namespace arrow
 

cpp/src/arrow/ipc/writer.h

@@ -177,13 +177,6 @@ Status ARROW_EXPORT WriteLargeRecordBatch(const RecordBatch& batch,
 Status ARROW_EXPORT WriteTensor(const Tensor& tensor, io::OutputStream* dst,
                                 int32_t* metadata_length, int64_t* body_length);
 
-/// Backwards-compatibility for Arrow < 0.4.0
-///
-#ifndef ARROW_NO_DEPRECATED_API
-using FileWriter = RecordBatchFileWriter;
-using StreamWriter = RecordBatchStreamWriter;
-#endif
-
 }  // namespace ipc
 }  // namespace arrow
 

python/pyarrow/__init__.py

@@ -114,7 +114,8 @@
 def _plasma_store_entry_point():
     """Entry point for starting the plasma store.
 
-    This can be used by invoking e. g. ``plasma_store -s /tmp/plasma -m 1000000000``
+    This can be used by invoking e.g.
+    ``plasma_store -s /tmp/plasma -m 1000000000``
     from the command line and will start the plasma_store executable with the
     given arguments.
     """
@@ -127,30 +128,10 @@ def _plasma_store_entry_point():
     process.wait()
 
 # ----------------------------------------------------------------------
-# 0.4.0 deprecations
+# Deprecations
 
 from pyarrow.util import _deprecate_class
 
-FileReader = _deprecate_class('FileReader',
-                              'RecordBatchFileReader',
-                              RecordBatchFileReader, '0.5.0')
-
-FileWriter = _deprecate_class('FileWriter',
-                              'RecordBatchFileWriter',
-                              RecordBatchFileWriter, '0.5.0')
-
-StreamReader = _deprecate_class('StreamReader',
-                                'RecordBatchStreamReader',
-                                RecordBatchStreamReader, '0.5.0')
-
-StreamWriter = _deprecate_class('StreamWriter',
-                                'RecordBatchStreamWriter',
-                                RecordBatchStreamWriter, '0.5.0')
-
-InMemoryOutputStream = _deprecate_class('InMemoryOutputStream',
-                                        'BufferOutputStream',
-                                        BufferOutputStream, '0.5.0')
-
 # Backwards compatibility with pyarrow < 0.6.0
 HdfsClient = _deprecate_class('HdfsClient', 'pyarrow.hdfs.connect',
                               hdfs.connect, '0.6.0')

python/pyarrow/ipc.py

@@ -155,7 +155,7 @@ def serialize_pandas(df):
         An object compatible with the buffer protocol
     """
     batch = pa.RecordBatch.from_pandas(df)
-    sink = pa.InMemoryOutputStream()
+    sink = pa.BufferOutputStream()
     writer = pa.RecordBatchStreamWriter(sink, batch.schema)
     writer.write_batch(batch)
     writer.close()

python/pyarrow/tests/test_deprecations.py

@@ -17,48 +17,7 @@
 
 # Check that various deprecation warnings are raised
 
+# flake8: noqa
+
 import pyarrow as pa
 import pytest
-
-
-def test_inmemory_output_stream():
-    with pytest.warns(FutureWarning):
-        stream = pa.InMemoryOutputStream()
-        assert isinstance(stream, pa.BufferOutputStream)
-
-
-def test_file_reader_writer():
-    data = [
-        pa.array([1, 2, 3, 4]),
-        pa.array(['foo', 'bar', 'baz', None]),
-        pa.array([True, None, False, True])
-    ]
-    batch = pa.RecordBatch.from_arrays(data, ['f0', 'f1', 'f2'])
-
-    sink = pa.BufferOutputStream()
-
-    with pytest.warns(FutureWarning):
-        stream_writer = pa.StreamWriter(sink, batch.schema)
-        assert isinstance(stream_writer, pa.RecordBatchStreamWriter)
-
-    sink2 = pa.BufferOutputStream()
-    with pytest.warns(FutureWarning):
-        file_writer = pa.FileWriter(sink2, batch.schema)
-        assert isinstance(file_writer, pa.RecordBatchFileWriter)
-
-    file_writer.write_batch(batch)
-    stream_writer.write_batch(batch)
-
-    file_writer.close()
-    stream_writer.close()
-
-    buf = sink.get_result()
-    buf2 = sink2.get_result()
-
-    with pytest.warns(FutureWarning):
-        stream_reader = pa.StreamReader(buf)
-        assert isinstance(stream_reader, pa.RecordBatchStreamReader)
-
-    with pytest.warns(FutureWarning):
-        file_reader = pa.FileReader(buf2)
-        assert isinstance(file_reader, pa.RecordBatchFileReader)