modules/core/src/main/java/org/apache/fluo/core/impl/TransactionImpl.java (21 lines): - line 198: // TODO cache? precache? - line 240: // TODO push visibility filtering to server side? - line 604: // TODO need to keep track of ranges read (not ranges passed in, but actual data read... user - line 710: // TODO avoid create col vis object - line 728: // TODO could use iterator that stops after 1st ACK. thought of using versioning iter - line 737: // TODO proper exception handling - line 841: // TODO Log an error if transaction is not closed (See FLUO-486) - line 852: // TODO could calculate as items are added/set - line 925: // TODO not sure threading is correct - line 978: // TODO convert this code to async - line 994: // TODO async - line 1000: // TODO handle case were data other tx has lock - line 1023: // TODO can this be simplified by pushing some code to the superclass? - line 1030: // TODO do async - line 1082: // TODO this step does not currently handle unknown - line 1091: // TODO handle unknown? - line 1148: // TODO let rollback be done lazily? this makes GC more difficult - line 1331: // TODO - how do we do the above without return a CF? - line 1339: // TODO async - line 1351: // TODO async - line 1475: // TODO do async modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoRowInputFormat.java (6 lines): - line 89: // TODO Auto-generated method stub - line 104: // TODO this uses non public Accumulo API! - line 166: // TODO support text - line 172: // TODO support binary data - line 180: // TODO let user set auths - line 181: // TODO let user set ranges modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoEntryInputFormat.java (5 lines): - line 89: // TODO Auto-generated method stub - line 104: // TODO this uses non public Accumulo API! - line 170: // TODO support binary data - line 178: // TODO let user set auths - line 179: // TODO let user set ranges modules/core/src/main/java/org/apache/fluo/core/impl/LockResolver.java (4 lines): - line 194: // TODO ensure this if ok if there concurrent rollback - line 237: // TODO review use of PrewriteIter here - line 251: // TODO handle other conditional writer cases - line 269: // TODO may be that a stronger sanity check that could be done here modules/core/src/main/java/org/apache/fluo/core/oracle/OracleServer.java (3 lines): - line 207: // TODO check that d is expected - line 208: // TODO check that still server when setting - line 209: // TODO make num allocated variable... when a server first starts allocate a small amount... the modules/core/src/main/java/org/apache/fluo/core/impl/Environment.java (2 lines): - line 172: // TODO the following is a big hack, this method is currently not exposed in API - line 254: // TODO create immutable wrapper modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/SnapshotIterator.java (2 lines): - line 184: // TODO handle case where dataPointer >=0, but no data was found - line 197: // TODO could require client to send version as a sanity check modules/core/src/main/java/org/apache/fluo/core/observer/v1/ObserverStoreV1.java (2 lines): - line 112: // TODO check that no workers are running... or make workers watch this znode - line 133: // TODO use a human readable serialized format like json modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/RollbackCheckIterator.java (2 lines): - line 84: // TODO can this optimization cause problems? - line 176: // TODO Auto-generated method stub modules/core/src/main/java/org/apache/fluo/core/impl/SnapshotScanner.java (1 line): - line 84: // TODO make configurable modules/core/src/main/java/org/apache/fluo/core/async/CommitManager.java (1 line): - line 142: // TODO should this wait? modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/PrewriteIterator.java (1 line): - line 260: // TODO Auto-generated method stub modules/core/src/main/java/org/apache/fluo/core/log/TracingTransaction.java (1 line): - line 257: // TODO log total # read, see fluo-426 modules/core/src/main/java/org/apache/fluo/core/impl/SharedBatchWriter.java (1 line): - line 103: // TODO error handling modules/core/src/main/java/org/apache/fluo/core/impl/ParallelSnapshotScanner.java (1 line): - line 119: // TODO hardcoded number of threads! modules/core/src/main/java/org/apache/fluo/core/impl/TxInfo.java (1 line): - line 53: // TODO ensure primary is visible modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/GarbageCollectionIterator.java (1 line): - line 135: // TODO check if its a notify modules/api/src/main/java/org/apache/fluo/api/config/SimpleConfiguration.java (1 line): - line 264: // TODO fix cast class; use Properties? modules/core/src/main/java/org/apache/fluo/core/util/ColumnUtil.java (1 line): - line 101: // TODO proper exception handling modules/core/src/main/java/org/apache/fluo/core/client/FluoAdminImpl.java (1 line): - line 295: // TODO set Fluo data version modules/accumulo/src/main/java/org/apache/fluo/accumulo/format/FluoFormatter.java (1 line): - line 116: // TODO can Value be made to extend Bytes w/o breaking API?