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 D | transform.cc | 36 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 D | transform.h | 33 class ARROW_EXPORT TransformInputStream : public InputStream { 38 TransformInputStream(std::shared_ptr<InputStream> wrapped, TransformFunc transform); 39 ~TransformInputStream() override;
|
H A D | memory_test.cc | 493 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 D | transform.cc | 36 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 D | transform.h | 33 class ARROW_EXPORT TransformInputStream : public InputStream { 38 TransformInputStream(std::shared_ptr<InputStream> wrapped, TransformFunc transform); 39 ~TransformInputStream() override;
|
H A D | memory_test.cc | 483 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 D | io.cc | 36 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 D | io.cc | 36 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__.py | 167 TransformInputStream, transcoding_input_stream,
|
H A D | io.pxi | 1350 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__.py | 175 TransformInputStream, transcoding_input_stream,
|
H A D | io.pxi | 1447 cdef class TransformInputStream(NativeFile): class 1460 self.set_input_stream(TransformInputStream.make_native( 1508 return TransformInputStream(stream, 1522 return TransformInputStream.make_native(
|