Change-Id: I9635f8eea06d0e30da15344ede32b69035723b35
This commit is contained in:
Wes McKinney committed 2016-11-28 13:13:12 -05:00
1 parent 85128f7add
commit aef4382313
3 files changed
+5 -7

No files matched your search

+2 -2
View File
@@ -201,8 +201,8 @@ Status FileReader::GetRecordBatch(int i, std::shared_ptr<RecordBatch>* batch) {
FileBlock block = footer_->record_batch(i);
std::shared_ptr<RecordBatchMetadata> metadata;
RETURN_NOT_OK(ReadRecordBatchMetadata(block.offset, block.metadata_length, file_.get(),
&metadata));
RETURN_NOT_OK(ReadRecordBatchMetadata(
block.offset, block.metadata_length, file_.get(), &metadata));
// TODO(wesm): ARROW-388 -- the buffer frame of reference is 0 (see
// ARROW-384).
+1 -3
View File
@@ -51,9 +51,7 @@ Status WriteSchema(const Schema* schema, std::shared_ptr<Buffer>* out) {
class Message::MessageImpl {
public:
explicit MessageImpl(const std::shared_ptr<Buffer>& buffer, int64_t offset)
: buffer_(buffer),
offset_(offset),
message_(nullptr) {}
: buffer_(buffer), offset_(offset), message_(nullptr) {}
Status Open() {
message_ = flatbuf::GetMessage(buffer_->data() + offset_);
+2 -2
View File
@@ -60,7 +60,7 @@ class Message;
// Container for serialized Schema metadata contained in an IPC message
class ARROW_EXPORT SchemaMetadata {
public:
SchemaMetadata(const std::shared_ptr<Message>& message);
explicit SchemaMetadata(const std::shared_ptr<Message>& message);
// Accepts an opaque flatbuffer pointer
SchemaMetadata(const std::shared_ptr<Message>& message, const void* schema);
@@ -99,7 +99,7 @@ struct BufferMetadata {
// Container for serialized record batch metadata contained in an IPC message
class ARROW_EXPORT RecordBatchMetadata {
public:
RecordBatchMetadata(const std::shared_ptr<Message>& message);
explicit RecordBatchMetadata(const std::shared_ptr<Message>& message);
~RecordBatchMetadata();
FieldMetadata field(int i) const;