Home
last modified time | relevance | path

Searched refs:TransformInputStream (Results 1 – 12 of 12) sorted by relevance

/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/io/
H A Dtransform.cc36 struct TransformInputStream::Impl {
38 TransformInputStream::TransformFunc transform_;
44 TransformInputStream::TransformFunc transform) in Impl()
60 TransformInputStream::TransformInputStream(std::shared_ptr<InputStream> wrapped, in TransformInputStream() function in arrow::io::TransformInputStream
64 TransformInputStream::~TransformInputStream() {} in ~TransformInputStream()
66 Status TransformInputStream::Close() { in Close()
71 Status TransformInputStream::Abort() { return impl_->wrapped_->Abort(); } in Abort()
73 bool TransformInputStream::closed() const { return impl_->closed_; } in closed()
75 Result<std::shared_ptr<Buffer>> TransformInputStream::Read(int64_t nbytes) { in Read()
86 Result<int64_t> TransformInputStream::Read(int64_t nbytes, void* out) { in Read()
[all …]
H A Dtransform.h33 class ARROW_EXPORT TransformInputStream : public InputStream {
38 TransformInputStream(std::shared_ptr<InputStream> wrapped, TransformFunc transform);
39 ~TransformInputStream() override;
H A Dmemory_test.cc493 TransformInputStream::TransformFunc transform() const { return T(); } in transform()
497 auto stream = std::make_shared<TransformInputStream>(wrapped, transform()); in TestEmptyStream()
512 auto stream = std::make_shared<TransformInputStream>( in TestBasics()
521 auto stream = std::make_shared<TransformInputStream>( in TestClose()
537 auto stream = std::make_shared<TransformInputStream>( in TestChunked()
554 auto stream = std::make_shared<TransformInputStream>( in TestStressChunked()
621 auto stream = std::make_shared<TransformInputStream>( in TEST()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/io/
H A Dtransform.cc36 struct TransformInputStream::Impl {
38 TransformInputStream::TransformFunc transform_;
44 TransformInputStream::TransformFunc transform) in Impl()
60 TransformInputStream::TransformInputStream(std::shared_ptr<InputStream> wrapped, in TransformInputStream() function in arrow::io::TransformInputStream
64 TransformInputStream::~TransformInputStream() {} in ~TransformInputStream()
66 Status TransformInputStream::Close() { in Close()
71 Status TransformInputStream::Abort() { return impl_->wrapped_->Abort(); } in Abort()
73 bool TransformInputStream::closed() const { return impl_->closed_; } in closed()
75 Result<std::shared_ptr<Buffer>> TransformInputStream::Read(int64_t nbytes) { in Read()
86 Result<int64_t> TransformInputStream::Read(int64_t nbytes, void* out) { in Read()
[all …]
H A Dtransform.h33 class ARROW_EXPORT TransformInputStream : public InputStream {
38 TransformInputStream(std::shared_ptr<InputStream> wrapped, TransformFunc transform);
39 ~TransformInputStream() override;
H A Dmemory_test.cc483 TransformInputStream::TransformFunc transform() const { return T(); } in transform()
487 auto stream = std::make_shared<TransformInputStream>(wrapped, transform()); in TestEmptyStream()
502 auto stream = std::make_shared<TransformInputStream>( in TestBasics()
511 auto stream = std::make_shared<TransformInputStream>( in TestClose()
527 auto stream = std::make_shared<TransformInputStream>( in TestChunked()
544 auto stream = std::make_shared<TransformInputStream>( in TestStressChunked()
611 auto stream = std::make_shared<TransformInputStream>( in TEST()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/python/
H A Dio.cc36 using arrow::io::TransformInputStream;
368 TransformInputStream::TransformFunc transform( in MakeTransformInputStream()
370 return std::make_shared<TransformInputStream>(std::move(wrapped), std::move(transform)); in MakeTransformInputStream()
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/python/
H A Dio.cc36 using arrow::io::TransformInputStream;
368 TransformInputStream::TransformFunc transform( in MakeTransformInputStream()
370 return std::make_shared<TransformInputStream>(std::move(wrapped), std::move(transform)); in MakeTransformInputStream()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/python/pyarrow/
H A D__init__.py167 TransformInputStream, transcoding_input_stream,
H A Dio.pxi1350 cdef class TransformInputStream(NativeFile): class
1353 self.set_input_stream(TransformInputStream.make_native(
1387 return TransformInputStream(stream,
1401 return TransformInputStream.make_native(
/dports/databases/arrow/apache-arrow-6.0.1/python/pyarrow/
H A D__init__.py175 TransformInputStream, transcoding_input_stream,
H A Dio.pxi1447 cdef class TransformInputStream(NativeFile): class
1460 self.set_input_stream(TransformInputStream.make_native(
1508 return TransformInputStream(stream,
1522 return TransformInputStream.make_native(