casacore
Loading...
Searching...
No Matches
BaseTable.h
Go to the documentation of this file.
1//# BaseTable.h: Abstract base class for tables
2//# Copyright (C) 1994,1995,1996,1997,1998,2000,2001,2002,2003
3//# Associated Universities, Inc. Washington DC, USA.
4//#
5//# This library is free software; you can redistribute it and/or modify it
6//# under the terms of the GNU Library General Public License as published by
7//# the Free Software Foundation; either version 2 of the License, or (at your
8//# option) any later version.
9//#
10//# This library is distributed in the hope that it will be useful, but WITHOUT
11//# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
12//# FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library General Public
13//# License for more details.
14//#
15//# You should have received a copy of the GNU Library General Public License
16//# along with this library; if not, write to the Free Software Foundation,
17//# Inc., 675 Massachusetts Ave, Cambridge, MA 02139, USA.
18//#
19//# Correspondence concerning AIPS++ should be addressed as follows:
20//# Internet email: casa-feedback@nrao.edu.
21//# Postal address: AIPS++ Project Office
22//# National Radio Astronomy Observatory
23//# 520 Edgemont Road
24//# Charlottesville, VA 22903-2475 USA
25
26#ifndef TABLES_BASETABLE_H
27#define TABLES_BASETABLE_H
28
29
30//# Includes
31#include <casacore/casa/aips.h>
32#include <casacore/tables/Tables/TableInfo.h>
33#include <casacore/tables/Tables/TableDesc.h>
34#include <casacore/tables/Tables/StorageOption.h>
35#include <casacore/casa/Utilities/Compare.h>
36#include <casacore/casa/BasicSL/String.h>
37#include <casacore/casa/IO/FileLocker.h>
38#include <casacore/casa/Arrays/ArrayFwd.h>
39#include <memory>
40
41#ifdef HAVE_MPI
42#include <mpi.h>
43#endif
44
45namespace casacore { //# NAMESPACE CASACORE - BEGIN
46
47//# Forward Declarations
48class RefTable;
49// class TableDesc; !Forward declaration not recognized SGI compiler
50class TableLock;
51class BaseColumn;
52class ColumnDesc;
53class TableRecord;
54class Record;
55class TableExprNode;
56class BaseTableIterator;
57class DataManager;
58class IPosition;
59template<class T> class Block;
60template<class T> class PtrBlock;
61class AipsIO;
62
63
64// <summary>
65// Abstract base class for tables
66// </summary>
67
68// <use visibility=local>
69
70// <reviewed reviewer="UNKNOWN" date="before2004/08/25" tests="">
71// </reviewed>
72
73// <prerequisite>
74//# Classes you should understand before using this one.
75// <li> Table
76// <li> Sort
77// <li> TableExprNode
78// </prerequisite>
79
80// <etymology>
81// BaseTable is the (abstract) base class for different kind of tables.
82// </etymology>
83
84// <synopsis>
85// BaseTables defines many virtual functions, which are actually
86// implemented in the underlying table classes like PlainTable and
87// RefTable. Other functions like sort and select are implemented
88// in BaseTable itself.
89//
90// The functions in BaseTable and its derived classes can only be
91// used by the table system classes. All user access is via the
92// envelope class Table, which references (counted) BaseTable.
93// </synopsis>
94
95// <todo asof="$DATE:$">
96//# A List of bugs, limitations, extensions or planned refinements.
97// <li> Implement function renameColumn, removeColumn.
98// </todo>
99
100
101class BaseTable: public std::enable_shared_from_this<BaseTable>
102{
103public:
104
105 // Initialize the object.
107
108#ifdef HAVE_MPI
109 // MPI version of the constructor
110 BaseTable (MPI_Comm mpiComm, const String& tableName, int tableOption, rownr_t nrrow);
111#endif
112
113 // Common code shared by the MPI constructor and non-MPI constructor
115
116 // The destructor will delete the table if needed.
117 virtual ~BaseTable();
118
119 // Copy constructor is forbidden, because copying a table requires
120 // some more knowledge (like table name of result).
121 BaseTable (const BaseTable&) = delete;
122
123 // Assignment is forbidden, because copying a table requires
124 // some more knowledge (like table name of result).
125 BaseTable& operator= (const BaseTable&) = delete;
126
127 // Is the table a null table?
128 // By default it is not.
129 virtual Bool isNull() const;
130
131 // Reopen the table for read/write.
132 virtual void reopenRW() = 0;
133
134 // Is the table stored in big or little endian format?
135 virtual Bool asBigEndian() const = 0;
136
137 // Get the storage option used for the table.
138 virtual const StorageOption& storageOption() const = 0;
139
140 // Is the table in use (i.e. open) in another process?
141 // If <src>checkSubTables</src> is set, it is also checked if
142 // a subtable is used in another process.
143 virtual Bool isMultiUsed(Bool checkSubTables) const = 0;
144
145 // Get the locking info.
146 virtual const TableLock& lockOptions() const = 0;
147
148 // Merge the given lock info with the existing one.
149 virtual void mergeLock (const TableLock& lockOptions) = 0;
150
151 // Has this process the read or write lock, thus can the table
152 // be read or written safely?
153 virtual Bool hasLock (FileLocker::LockType) const = 0;
154
155 // Try to lock the table for read or write access.
156 virtual Bool lock (FileLocker::LockType, uInt nattempts) = 0;
157
158 // Unlock the table. This will also synchronize the table data,
159 // thus force the data to be written to disk.
160 virtual void unlock() = 0;
161
162 // Flush the table, i.e. write it to disk.
163 virtual void flush (Bool fsync, Bool recursive) = 0;
164
165 // Resync the Table object with the table file.
166 virtual void resync() = 0;
167
168 // Get the modify counter.
169 virtual uInt getModifyCounter() const = 0;
170
171 // Set the table to being changed. By default it does nothing.
172 virtual void setTableChanged();
173
174 // Do not write the table (used in in case of exceptions).
176 { noWrite_p = True; }
177
178 // Test if this table is writable.
179 // This tells if values can be put into a column.
180 virtual Bool isWritable() const = 0;
181
182 // Test if the given column is writable.
183 // <group>
184 Bool isColumnWritable (const String& columnName) const;
185 Bool isColumnWritable (uInt columnIndex) const;
186 // </group>
187
188 // Test if the given column is stored (otherwise it is virtual).
189 // <group>
190 Bool isColumnStored (const String& columnName) const;
191 Bool isColumnStored (uInt columnIndex) const;
192 // </group>
193
194 // Get the table name.
195 const String& tableName() const
196 { return name_p; }
197
198 // Get the names of the tables this table consists of.
199 // The default implementation adds the name of this table to the block.
200 virtual void getPartNames (Block<String>& names, Bool recursive) const;
201
202 // Rename the table.
203 // The following options can be given:
204 // <dl>
205 // <dt> Table::Update
206 // <dd> A table with this name must already exists, which will be
207 // overwritten. When succesfully renamed, the table is unmarked
208 // for delete (if necessary).
209 // <dt> Table::New
210 // <dd> When a table with this name exists, it will be overwritten.
211 // When succesfully renamed, the table is unmarked
212 // for delete (if necessary).
213 // <dt> Table::NewNoReplace
214 // <dd> When a table with this name already exists, an exception
215 // is thrown. When succesfully renamed, the table
216 // is unmarked for delete (if necessary).
217 // <dt> Table::Scratch
218 // <dd> Same as Table::New, but followed by markForDelete().
219 // </dl>
220 // The rename function in this base class renames the table file.
221 // In a derived class (e.g. PlainTable) the function should also
222 // be implemented to rename subtables in its keywords.
223 virtual void rename (const String& newName, int tableOption);
224
225 // Copy the table and all its subtables.
226 // The default implementation of deepCopy is to call copy.
227 // The following options can be given:
228 // <dl>
229 // <dt> Table::New
230 // <dd> When a table with this name exists, it will be overwritten.
231 // <dt> Table::NewNoReplace
232 // <dd> When a table with this name already exists, an exception
233 // is thrown.
234 // <dt> Table::Scratch
235 // <dd> Same as Table::New, but followed by markForDelete().
236 // </dl>
237 // <group>
238 virtual void copy (const String& newName, int tableOption) const;
239 virtual void deepCopy (const String& newName,
240 const Record& dataManagerInfo,
241 const StorageOption&,
242 int tableOption,
243 Bool valueCopy,
244 int endianFormat,
245 Bool noRows) const;
246 // </group>
247
248 // Get the table type.
249 // By default it returns Table::Plain.
250 virtual int tableType() const;
251
252 // Get the table option.
253 int tableOption() const
254 { return option_p; }
255
256 // Mark the table for delete.
257 // This means that the underlying table gets deleted when it is
258 // actually destructed.
259 // The scratchCallback function is called when needed.
260 void markForDelete (Bool callback, const String& oldName);
261
262 // Unmark the table for delete.
263 // This means the underlying table does not get deleted when destructed.
264 // The scratchCallback function is called when needed.
265 void unmarkForDelete (Bool callback, const String& oldName);
266
267 // Test if the table is marked for delete.
269 { return delete_p; }
270
271 // Get the table description.
272 const TableDesc& tableDesc() const
273 { return (!tdescPtr_p ? makeEmptyTableDesc() : *tdescPtr_p); }
274
275 // Get the actual table description.
276 virtual TableDesc actualTableDesc() const = 0;
277
278 // Get the data manager info.
279 virtual Record dataManagerInfo() const = 0;
280
281 // Show the table structure (implementation of Table::showStructure).
282 void showStructure (std::ostream&,
283 Bool showDataMan,
284 Bool showColumns,
285 Bool showSubTables,
286 Bool sortColumns,
287 Bool cOrder);
288
289 // Get readonly access to the table keyword set.
290 virtual TableRecord& keywordSet() = 0;
291
292 // Get read/write access to the table keyword set.
293 // This requires that the table is locked (or it gets locked
294 // when using AutoLocking mode).
295 virtual TableRecord& rwKeywordSet() = 0;
296
297 // Get access to the TableInfo object.
299 { return info_p; }
300
301 // Get the table info of the table with the given name.
302 // An empty object is returned when the table is unknown.
304
305 // Write the TableInfo object.
306 virtual void flushTableInfo();
307
308 // Get number of rows.
309 rownr_t nrow() const
310 { return nrrow_p; }
311
312 // Get a column object using its index.
313 virtual BaseColumn* getColumn (uInt columnIndex) const = 0;
314
315 // Get a column object using its name.
316 virtual BaseColumn* getColumn (const String& columnName) const = 0;
317
318 // Test if it is possible to add a row to this table.
319 virtual Bool canAddRow() const;
320
321 // Add one or more rows and possibly initialize them.
322 // This will fail for tables not supporting addition of rows.
323 virtual void addRow (rownr_t nrrow = 1, Bool initialize = True);
324
325 // Test if it is possible to remove a row from this table.
326 virtual Bool canRemoveRow() const;
327
328 // Remove rows.
329 // This will fail for tables not supporting removal of rows.
330 // <note role=tip>
331 // The following code fragments do NOT have the same result:
332 // <srcblock>
333 // tab.removeRow (10); // remove row 10
334 // tab.removeRow (20); // remove row 20, which was 21
335 //
336 // Vector<rownr_t> vec(2);
337 // vec(0) = 10;
338 // vec(1) = 20;
339 // tab.removeRow (vec); // remove row 10 and 20
340 // </srcblock>
341 // because in the first fragment removing row 10 turns the former
342 // row 21 into row 20.
343 // </note>
344 // <group>
345 virtual void removeRow (rownr_t rownr);
346 void removeRow (const Vector<rownr_t>& rownrs);
347 void removeRow (const Vector<uInt>& rownrs);
348 // </group>
349
350 // Find the data manager with the given name or for the given column.
351 virtual DataManager* findDataManager (const String& name,
352 Bool byColumn) const = 0;
353
354 // Select rows using the given expression (which can be null).
355 // Skip first <src>offset</src> matching rows.
356 // Return at most <src>maxRow</src> matching rows.
357 std::shared_ptr<BaseTable> select (const TableExprNode&,
358 rownr_t maxRow, rownr_t offset);
359
360 // Select maxRow rows and skip first offset rows. maxRow=0 means all.
361 std::shared_ptr<BaseTable> select (rownr_t maxRow, rownr_t offset);
362
363 // Select rows using a vector of row numbers.
364 std::shared_ptr<BaseTable> select (const Vector<rownr_t>& rownrs);
365
366 // Select rows using a mask block.
367 // The length of the block must match the number of rows in the table.
368 // If True, the corresponding row will be selected.
369 std::shared_ptr<BaseTable> select (const Block<Bool>& mask);
370
371 // Project the given columns (i.e. select the columns).
372 std::shared_ptr<BaseTable> project (const Block<String>& columnNames);
373
374 // Do logical operations on a table.
375 // <group>
376 // intersection with another table
377 std::shared_ptr<BaseTable> tabAnd (BaseTable*);
378 // union with another table
379 std::shared_ptr<BaseTable> tabOr (BaseTable*);
380 // subtract another table
381 std::shared_ptr<BaseTable> tabSub (BaseTable*);
382 // xor with another table
383 std::shared_ptr<BaseTable> tabXor (BaseTable*);
384 // take complement
385 std::shared_ptr<BaseTable> tabNot ();
386 // </group>
387
388 // Sort a table on one or more columns of scalars.
389 std::shared_ptr<BaseTable> sort
390 (const Block<String>& columnNames,
391 const Block<std::shared_ptr<BaseCompare>>& compareObjects,
392 const Block<Int>& sortOrder, int sortOption,
393 std::shared_ptr<Vector<rownr_t>> sortIterBoundaries = nullptr,
394 std::shared_ptr<Vector<size_t>> sortIterKeyIdxChange = nullptr);
395
396 // Create an iterator.
398 const Block<std::shared_ptr<BaseCompare>>&,
399 const Block<Int>& orders, int option,
400 bool cacheIterationBoundaries = false);
401
402 // Add one or more columns to the table.
403 // The default implementation throws an "invalid operation" exception.
404 // <group>
405 virtual void addColumn (const ColumnDesc& columnDesc, Bool addToParent);
406 virtual void addColumn (const ColumnDesc& columnDesc,
407 const String& dataManager, Bool byName,
408 Bool addToParent);
409 virtual void addColumn (const ColumnDesc& columnDesc,
410 const DataManager& dataManager, Bool addToParent);
411 virtual void addColumn (const TableDesc& tableDesc,
412 const DataManager& dataManager, Bool addToParent);
413 // </group>
414
415 // Add one or more columns to the table.
416 // The data manager to use is described in the record.
417 void addColumns (const TableDesc& tableDesc, const Record& dmInfo,
418 Bool addToParent);
419
420 // Test if columns can be removed.
421 virtual Bool canRemoveColumn (const Vector<String>& columnNames) const = 0;
422
423 // Remove columns.
424 virtual void removeColumn (const Vector<String>& columnNames) = 0;
425
426 // Check if the set of columns can be removed.
427 // It checks if columns have not been specified twice and it
428 // checks if they exist.
429 // If the flag is set an exception is thrown if errors are found.
431 Bool throwException) const;
432
433 // Test if a column can be renamed.
434 virtual Bool canRenameColumn (const String& columnName) const = 0;
435
436 // Rename a column.
437 virtual void renameColumn (const String& newName,
438 const String& oldName) = 0;
439
440 // Rename a hypercolumn.
441 virtual void renameHypercolumn (const String& newName,
442 const String& oldName) = 0;
443
444 // Get a vector of row numbers.
445 // By default it returns the row numbers 0..nrrow()-1.
446 // It needs to be implemented for RefTable only.
448
449 // Get pointer to root table (i.e. parent of a RefTable).
450 // Default it is this table.
451 // It is meant for the reference tables after a select or sort which
452 // can then still name their parent as the root.
453 virtual BaseTable* root();
454
455 // Tell if the table is in row order.
456 // By default it is, since normally a table is always in row order.
457 // It is meant for RefTable-s, where the rows can be in
458 // another (sorted) order.
459 virtual Bool rowOrder() const;
460
461 // By the default the table cannot return the storage of rownrs.
462 // That can only be done by a RefTable, where it is implemented.
464
465 // Adjust the row numbers to be the actual row numbers in the
466 // root table. This is, for instance, used when a RefTable is sorted.
467 // Optionally it also determines if the resulting rows are in order.
468 virtual Bool adjustRownrs (rownr_t nrrow, Vector<rownr_t>& rownrs,
469 Bool determineOrder) const;
470
471 // Do the actual sort.
472 // The default implementation is suitable for almost all cases.
473 // Only in RefTable a smarter implementation is provided.
474 virtual std::shared_ptr<BaseTable> doSort
476 const Block<std::shared_ptr<BaseCompare>>&,
477 const Block<Int>& sortOrder,
478 int sortOption,
479 std::shared_ptr<Vector<rownr_t>> sortIterBoundaries,
480 std::shared_ptr<Vector<size_t>> sortIterKeyIdxChange);
481
482 // Create a RefTable object.
483 std::shared_ptr<RefTable> makeRefTable (Bool rowOrder,
484 rownr_t initialNrrow);
485
486 // Check if the row number is valid.
487 // It throws an exception if out of range.
488 void checkRowNumber (rownr_t rownr) const
489 { if (rownr >= nrrow_p + nrrowToAdd_p) checkRowNumberThrow (rownr); }
490
491 // Get the table's trace-id.
492 int traceId() const
493 { return itsTraceId; }
494
495protected:
496 std::weak_ptr<BaseTable> thisPtr_p; //# pointer to itself (to make shared_ptr)
497 rownr_t nrrow_p; //# #rows in this table
498 rownr_t nrrowToAdd_p; //# #rows to be added
499 std::shared_ptr<TableDesc> tdescPtr_p; //# Pointer to table description
500 String name_p; //# table name
501 int option_p; //# Table constructor option
502 Bool noWrite_p; //# False = do not write the table
503 Bool delete_p; //# True = delete when destructed
504 TableInfo info_p; //# Table information (type, etc.)
505 Bool madeDir_p; //# True = table dir has been created
506 int itsTraceId; //# table-id for TableTrace tracing
507
508
509 // Do the callback for scratch tables (if callback is set).
510 void scratchCallback (Bool isScratch, const String& oldName) const;
511
512 // Create the table directory when needed (and possible).
513 // When the file already exists, check if it is a directory.
514 // It returns True when it actually created the directory.
516
517 // Make a true deep copy of the table.
518 // The table is flushed before making the copy.
519 void trueDeepCopy (const String& newName,
520 const Record& dataManagerInfo,
521 const StorageOption&,
522 int tableOption,
523 int endianFormat,
524 Bool noRows) const;
525
526 // Prepare for copying or renaming a table.
527 // It checks if the target table already exists and removes it
528 // when necessary.
529 void prepareCopyRename (const String& newName, int tableOption) const;
530
531 // Rename the subtables (used by rename function).
532 virtual void renameSubTables (const String& newName,
533 const String& oldName);
534
535 // Check if the table already exists.
536 // Throw an exception if so.
538
539 // Test if the table is opened for write.
541
542 // Start writing a table. It does a putstart and writes <src>nrrow_p</src>.
543 // It should be ended by calling <src>writeEnd</src>.
544 void writeStart (AipsIO&, Bool bigEndian);
545
546 // End writing a table.
548
549 // Should the table be written.
550 // This flag is False if an exception was thrown.
552 { return noWrite_p; }
553
554 // Read the TableInfo object.
556
557private:
558 // Show a possible extra table structure header.
559 // It is used by e.g. RefTable to show which table is referenced.
560 virtual void showStructureExtra (std::ostream&) const;
561
562 // Show the info of the given columns.
563 // Sort the columns if needed.
564 void showColumnInfo (ostream& os, const TableDesc&, uInt maxNameLength,
565 const Array<String>& columnNames, Bool sort,
566 Bool cOrder) const;
567
568 // Throw an exception for checkRowNumber.
569 void checkRowNumberThrow (rownr_t rownr) const;
570
571 // Check if the tables combined in a logical operation have the
572 // same root.
573 void logicCheck (BaseTable* that);
574
575 // Get the rownrs of the table in ascending order to be
576 // used in the logical operation on the table.
578
579 // Make an empty table description.
580 // This is used if one asks for the description of a NullTable.
581 // Creating an empty TableDesc in the NullTable takes too much time.
582 // Furthermore it causes static initialization order problems.
584
585 // Make the name absolute.
586 // It first checks if the name contains valid characters (not only . and /).
587 String makeAbsoluteName (const String& name) const;
588
589#ifdef HAVE_MPI
590 // MPI communicator for parallel I/O.
591 // When using an MPI-disabled casacore, MPI applications have always been
592 // able to create Tables from each rank independently. Defaulting this
593 // communicator to MPI_COMM_SELF preserves that expectation.
594 MPI_Comm itsMpiComm = MPI_COMM_SELF;
595#endif
596};
597
598
599
600
601} //# NAMESPACE CASACORE - END
602
603#endif
virtual Vector< rownr_t > & rowStorage()
By the default the table cannot return the storage of rownrs.
virtual TableRecord & rwKeywordSet()=0
Get read/write access to the table keyword set.
virtual void addColumn(const ColumnDesc &columnDesc, const String &dataManager, Bool byName, Bool addToParent)
virtual Bool adjustRownrs(rownr_t nrrow, Vector< rownr_t > &rownrs, Bool determineOrder) const
Adjust the row numbers to be the actual row numbers in the root table.
void BaseTableCommon(const String &tableName, int tableOption, rownr_t nrrow)
Common code shared by the MPI constructor and non-MPI constructor.
std::shared_ptr< BaseTable > select(const Block< Bool > &mask)
Select rows using a mask block.
Bool openedForWrite() const
Test if the table is opened for write.
virtual void renameHypercolumn(const String &newName, const String &oldName)=0
Rename a hypercolumn.
virtual void flushTableInfo()
Write the TableInfo object.
void removeRow(const Vector< uInt > &rownrs)
void unmarkForDelete(Bool callback, const String &oldName)
Unmark the table for delete.
virtual void reopenRW()=0
Reopen the table for read/write.
virtual BaseColumn * getColumn(const String &columnName) const =0
Get a column object using its name.
std::shared_ptr< BaseTable > select(rownr_t maxRow, rownr_t offset)
Select maxRow rows and skip first offset rows.
Bool isColumnStored(uInt columnIndex) const
virtual Bool isNull() const
Is the table a null table? By default it is not.
virtual void renameColumn(const String &newName, const String &oldName)=0
Rename a column.
const String & tableName() const
Get the table name.
Definition BaseTable.h:195
BaseTable(MPI_Comm mpiComm, const String &tableName, int tableOption, rownr_t nrrow)
MPI version of the constructor.
void showColumnInfo(ostream &os, const TableDesc &, uInt maxNameLength, const Array< String > &columnNames, Bool sort, Bool cOrder) const
Show the info of the given columns.
void throwIfTableExists()
Check if the table already exists.
Bool isMarkedForDelete() const
Test if the table is marked for delete.
Definition BaseTable.h:268
virtual void copy(const String &newName, int tableOption) const
Copy the table and all its subtables.
virtual Bool asBigEndian() const =0
Is the table stored in big or little endian format?
Bool makeTableDir()
Create the table directory when needed (and possible).
virtual Bool lock(FileLocker::LockType, uInt nattempts)=0
Try to lock the table for read or write access.
virtual BaseTable * root()
Get pointer to root table (i.e.
std::shared_ptr< BaseTable > sort(const Block< String > &columnNames, const Block< std::shared_ptr< BaseCompare > > &compareObjects, const Block< Int > &sortOrder, int sortOption, std::shared_ptr< Vector< rownr_t > > sortIterBoundaries=nullptr, std::shared_ptr< Vector< size_t > > sortIterKeyIdxChange=nullptr)
Sort a table on one or more columns of scalars.
Bool isColumnWritable(const String &columnName) const
Test if the given column is writable.
void writeStart(AipsIO &, Bool bigEndian)
Start writing a table.
virtual Bool canRemoveColumn(const Vector< String > &columnNames) const =0
Test if columns can be removed.
void removeRow(const Vector< rownr_t > &rownrs)
virtual void addColumn(const ColumnDesc &columnDesc, Bool addToParent)
Add one or more columns to the table.
const TableDesc & tableDesc() const
Get the table description.
Definition BaseTable.h:272
virtual void getPartNames(Block< String > &names, Bool recursive) const
Get the names of the tables this table consists of.
BaseTable(const String &tableName, int tableOption, rownr_t nrrow)
Initialize the object.
virtual void showStructureExtra(std::ostream &) const
Show a possible extra table structure header.
virtual Vector< rownr_t > rowNumbers() const
Get a vector of row numbers.
virtual void removeColumn(const Vector< String > &columnNames)=0
Remove columns.
void writeEnd(AipsIO &)
End writing a table.
BaseTable(const BaseTable &)=delete
Copy constructor is forbidden, because copying a table requires some more knowledge (like table name ...
virtual void removeRow(rownr_t rownr)
Remove rows.
virtual void addRow(rownr_t nrrow=1, Bool initialize=True)
Add one or more rows and possibly initialize them.
void checkRowNumberThrow(rownr_t rownr) const
Throw an exception for checkRowNumber.
virtual Bool isMultiUsed(Bool checkSubTables) const =0
Is the table in use (i.e.
std::shared_ptr< BaseTable > tabNot()
take complement
std::shared_ptr< BaseTable > tabOr(BaseTable *)
union with another table
std::shared_ptr< BaseTable > tabXor(BaseTable *)
xor with another table
virtual ~BaseTable()
The destructor will delete the table if needed.
std::shared_ptr< BaseTable > tabSub(BaseTable *)
subtract another table
void doNotWrite()
Do not write the table (used in in case of exceptions).
Definition BaseTable.h:175
void prepareCopyRename(const String &newName, int tableOption) const
Prepare for copying or renaming a table.
std::shared_ptr< BaseTable > project(const Block< String > &columnNames)
Project the given columns (i.e.
virtual Bool canRenameColumn(const String &columnName) const =0
Test if a column can be renamed.
Bool isColumnStored(const String &columnName) const
Test if the given column is stored (otherwise it is virtual).
virtual Bool isWritable() const =0
Test if this table is writable.
void trueDeepCopy(const String &newName, const Record &dataManagerInfo, const StorageOption &, int tableOption, int endianFormat, Bool noRows) const
Make a true deep copy of the table.
virtual void resync()=0
Resync the Table object with the table file.
std::shared_ptr< TableDesc > tdescPtr_p
Definition BaseTable.h:499
virtual void rename(const String &newName, int tableOption)
Rename the table.
virtual Bool canAddRow() const
Test if it is possible to add a row to this table.
rownr_t nrow() const
Get number of rows.
Definition BaseTable.h:309
virtual TableRecord & keywordSet()=0
Get readonly access to the table keyword set.
std::shared_ptr< BaseTable > select(const Vector< rownr_t > &rownrs)
Select rows using a vector of row numbers.
MPI_Comm itsMpiComm
MPI communicator for parallel I/O.
Definition BaseTable.h:594
virtual Bool rowOrder() const
Tell if the table is in row order.
virtual uInt getModifyCounter() const =0
Get the modify counter.
virtual std::shared_ptr< BaseTable > doSort(PtrBlock< BaseColumn * > &, const Block< std::shared_ptr< BaseCompare > > &, const Block< Int > &sortOrder, int sortOption, std::shared_ptr< Vector< rownr_t > > sortIterBoundaries, std::shared_ptr< Vector< size_t > > sortIterKeyIdxChange)
Do the actual sort.
int tableOption() const
Get the table option.
Definition BaseTable.h:253
virtual void unlock()=0
Unlock the table.
int traceId() const
Get the table's trace-id.
Definition BaseTable.h:492
void markForDelete(Bool callback, const String &oldName)
Mark the table for delete.
BaseTableIterator * makeIterator(const Block< String > &columnNames, const Block< std::shared_ptr< BaseCompare > > &, const Block< Int > &orders, int option, bool cacheIterationBoundaries=false)
Create an iterator.
virtual TableDesc actualTableDesc() const =0
Get the actual table description.
virtual void mergeLock(const TableLock &lockOptions)=0
Merge the given lock info with the existing one.
void scratchCallback(Bool isScratch, const String &oldName) const
Do the callback for scratch tables (if callback is set).
virtual Bool canRemoveRow() const
Test if it is possible to remove a row from this table.
BaseTable & operator=(const BaseTable &)=delete
Assignment is forbidden, because copying a table requires some more knowledge (like table name of res...
virtual Record dataManagerInfo() const =0
Get the data manager info.
virtual DataManager * findDataManager(const String &name, Bool byColumn) const =0
Find the data manager with the given name or for the given column.
std::shared_ptr< BaseTable > select(const TableExprNode &, rownr_t maxRow, rownr_t offset)
Select rows using the given expression (which can be null).
virtual void addColumn(const ColumnDesc &columnDesc, const DataManager &dataManager, Bool addToParent)
const TableDesc & makeEmptyTableDesc() const
Make an empty table description.
std::weak_ptr< BaseTable > thisPtr_p
Definition BaseTable.h:496
virtual Bool hasLock(FileLocker::LockType) const =0
Has this process the read or write lock, thus can the table be read or written safely?
TableInfo & tableInfo()
Get access to the TableInfo object.
Definition BaseTable.h:298
void addColumns(const TableDesc &tableDesc, const Record &dmInfo, Bool addToParent)
Add one or more columns to the table.
virtual void flush(Bool fsync, Bool recursive)=0
Flush the table, i.e.
virtual int tableType() const
Get the table type.
std::shared_ptr< BaseTable > tabAnd(BaseTable *)
Do logical operations on a table.
void checkRowNumber(rownr_t rownr) const
Check if the row number is valid.
Definition BaseTable.h:488
Bool checkRemoveColumn(const Vector< String > &columnNames, Bool throwException) const
Check if the set of columns can be removed.
virtual void addColumn(const TableDesc &tableDesc, const DataManager &dataManager, Bool addToParent)
std::shared_ptr< RefTable > makeRefTable(Bool rowOrder, rownr_t initialNrrow)
Create a RefTable object.
virtual void deepCopy(const String &newName, const Record &dataManagerInfo, const StorageOption &, int tableOption, Bool valueCopy, int endianFormat, Bool noRows) const
virtual const StorageOption & storageOption() const =0
Get the storage option used for the table.
Vector< rownr_t > logicRows()
Get the rownrs of the table in ascending order to be used in the logical operation on the table.
String makeAbsoluteName(const String &name) const
Make the name absolute.
void getTableInfo()
Read the TableInfo object.
Bool isColumnWritable(uInt columnIndex) const
virtual BaseColumn * getColumn(uInt columnIndex) const =0
Get a column object using its index.
static TableInfo tableInfo(const String &tableName)
Get the table info of the table with the given name.
Bool shouldNotWrite() const
Should the table be written.
Definition BaseTable.h:551
void logicCheck(BaseTable *that)
Check if the tables combined in a logical operation have the same root.
virtual void renameSubTables(const String &newName, const String &oldName)
Rename the subtables (used by rename function).
void showStructure(std::ostream &, Bool showDataMan, Bool showColumns, Bool showSubTables, Bool sortColumns, Bool cOrder)
Show the table structure (implementation of Table::showStructure).
virtual const TableLock & lockOptions() const =0
Get the locking info.
virtual void setTableChanged()
Set the table to being changed.
simple 1-D array
Definition Block.h:198
Abstract base class for a data manager.
LockType
Define the possible lock types.
Definition FileLocker.h:93
A drop-in replacement for Block<T*>.
Definition Block.h:812
String: the storage and methods of handling collections of characters.
Definition String.h:223
this file contains all the compiler specific defines
Definition mainpage.dox:28
unsigned int uInt
Definition aipstype.h:49
LatticeExprNode mask(const LatticeExprNode &expr)
This function returns the mask of the given expression.
bool Bool
Define the standard types used by Casacore.
Definition aipstype.h:40
const Bool True
Definition aipstype.h:41
uInt64 rownr_t
Define the type of a row number in a table.
Definition aipsxtype.h:44