modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java (3 lines): - line 58: // TODO sanity check key type based on type params - line 59: // TODO defer creating classes until needed.. so that its not done during Fluo init - line 92: // TODO maybe add for stream and iterable modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/function/AccumuloWriter.java (2 lines): - line 63: // TODO need to close batch writer - line 114: // TODO: fix this write to static and remove findbugs max rank override in pom.xml modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportBucket.java (2 lines): - line 67: // TODO encode in a more robust way... but for now fail early - line 173: // TODO maybe leave as Bytes? modules/core/src/main/java/org/apache/fluo/recipes/core/combine/CombineQueueImpl.java (2 lines): - line 124: // TODO set if not exists would be comforting here.... but - line 303: // TODO could clear these as converted to objects to avoid double memory usage modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportObserver.java (2 lines): - line 46: // TODO defer loading classes... so that not done during fluo init - line 47: // TODO move class loading to centralized place... also attempt to check type params modules/core/src/main/java/org/apache/fluo/recipes/core/types/TypedSnapshotBase.java (1 line): - line 42: // TODO need to refactor column to use Encoder modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportObserverImpl.java (1 line): - line 42: // TODO move class loading to centralized place... also attempt to check type params modules/core/src/main/java/org/apache/fluo/recipes/core/serialization/SimpleSerializer.java (1 line): - line 31: // TODO refactor to support reuse of objects and byte arrays??? modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/function/AeFluentConfigurator.java (1 line): - line 46: // TODO Auto-generated method stub modules/core/src/main/java/org/apache/fluo/recipes/core/map/CollisionFreeMapObserver.java (1 line): - line 52: // TODO constants