odps-sdk-impl/odps-mapred-local/src/main/java/com/aliyun/odps/mapred/local/MapDriver.java (20 lines): - line 169: // TODO Auto-generated method stub - line 175: // TODO Auto-generated method stub - line 181: // TODO Auto-generated method stub - line 187: // TODO Auto-generated method stub - line 193: // TODO Auto-generated method stub - line 199: // TODO Auto-generated method stub - line 205: // TODO Auto-generated method stub - line 211: // TODO Auto-generated method stub - line 217: // TODO Auto-generated method stub - line 223: // TODO Auto-generated method stub - line 311: // TODO Auto-generated method stub - line 317: // TODO Auto-generated method stub - line 323: // TODO Auto-generated method stub - line 329: // TODO Auto-generated method stub - line 335: // TODO Auto-generated method stub - line 341: // TODO Auto-generated method stub - line 347: // TODO Auto-generated method stub - line 353: // TODO Auto-generated method stub - line 359: // TODO Auto-generated method stub - line 365: // TODO Auto-generated method stub odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/LOTGenerator.java (10 lines): - line 150: // FIXME multi-mapper - line 159: // FIXME multi-insert from m-r's mapper - line 198: // FIXME currently UDTF need a output column - line 211: // FIXME types/signature - line 212: // FIXME use col name or not? - line 386: // TODO combiner (currently run in mapper) - line 612: // TODO properties to pb fields - line 1219: // FIXME parse resource - line 1244: // TODO merge these resource aliases - line 1260: // TODO set per table streaming properties? odps-sdk-impl/odps-mapred-local/src/main/java/com/aliyun/odps/mapred/local/ReduceDriver.java (8 lines): - line 164: // TODO Auto-generated method stub - line 170: // TODO Auto-generated method stub - line 176: // TODO Auto-generated method stub - line 182: // TODO Auto-generated method stub - line 188: // TODO Auto-generated method stub - line 194: // TODO Auto-generated method stub - line 200: // TODO Auto-generated method stub - line 206: // TODO Auto-generated method stub odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/streaming/PipeMapRed.java (6 lines): - line 412: // TODO split key-value to fields - line 413: // FIXME key-value to table record mapping - line 414: // TODO convert string fileds to output schema type - line 429: // FIXME shuffle key-value both just single Text field now. - line 503: // FIXME should have checked at client side? - line 512: // TODO provide escaped field content with error msg? odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/Function.java (5 lines): - line 112: // TODO: replace with a static builder - line 143: // TODO: replace with a static builder - line 200: // TODO: replace with a static builder - line 211: // TODO: replace with a static builder - line 309: // TODO: replace with a static builder odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/TableResource.java (5 lines): - line 35: // TODO: replace with a static builder - line 47: // TODO: replace with a static builder - line 60: // TODO: replace with a static builder - line 76: // TODO: replace with a static builder - line 102: // TODO: replace with a static builder odps-sdk-impl/odps-udf-example/src/main/java/com/aliyun/odps/udf/example/text/TextExtractor.java (4 lines): - line 144: // TODO: a option to throw or ignore - line 165: // TODO: make NULL representation configurable - line 201: // TODO: add support - line 209: // TODO: change to setWithNoValidation when becomes available odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/streaming/StreamJob.java (4 lines): - line 347: // TODO other per table input config: cols, etc. - line 668: // TODO reducer lib - line 745: // FIXME this partitioner would be implemented by the StreamingOperator at runtime... - line 784: // FIXME resources linkname odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/Table.java (3 lines): - line 946: // TODO: isVirtualView can be determined by both table type and schema - line 1000: // TODO: isVirtualView can be determined by both table type and schema - line 2023: // TODO: not sure this sql support schema odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/data/DefaultRecordReader.java (3 lines): - line 153: // TODO: support MAP - line 157: // TODO: support ARRAY - line 218: // TODO: support STRUCT odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/Classification.java (3 lines): - line 110: // TODO: server side unsupported yet - line 151: // TODO: server side unsupported - line 332: // TODO: server side unsupported odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/Resource.java (2 lines): - line 279: // TODO: replace with a static builder - line 302: // TODO: replace with a static builder odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/streaming/PipeReducer.java (2 lines): - line 115: // FIXME shuffle key-value both just single Text field now. - line 120: // FIXME field split & type convert odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/arrow/writers/ArrowBatchWriter.java (2 lines): - line 71: // TODO: arrow 12.0 support compress unloader, remove it - line 77: // TODO: validate root schema odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/DataSchema.java (2 lines): - line 243: // TODO: nullable - line 250: // TODO: nullable odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/configuration/ArrowOptions.java (2 lines): - line 31: // TODO: arrow extension mode - line 32: // TODO: arrow data version odps-sdk/odps-sdk-graph/src/main/java/com/aliyun/odps/graph/job/NetworkRunningJob.java (2 lines): - line 273: // TODO Auto-generated method stub - line 279: // TODO Auto-generated method stub odps-sdk-impl/odps-graph-local/src/main/java/com/aliyun/odps/graph/local/message/SuperStepBuffer.java (1 line): - line 99: // TODO Auto-generated method stub odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/write/TableUpsertSession.java (1 line): - line 23: // TODO: upsert interface odps-sdk/odps-sdk-udf/src/main/java/com/aliyun/odps/udf/InputFormat.java (1 line): - line 10: * TODO: see if we can remove this odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/utils/NameSpaceSchemaUtils.java (1 line): - line 31: // TODO: HACK for internal test, remove this later odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/TableClient.java (1 line): - line 4: // TODO: odps-sdk/odps-sdk-commons/src/main/java/com/aliyun/odps/io/BigDecimalWritable.java (1 line): - line 77: //TODO consider trying to do something a big more optimizied odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/write/TableStreamingWriteSession.java (1 line): - line 23: // TODO: streaming sink interface odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/sqa/commandapi/MergeTaskCommand.java (1 line): - line 47: // TODO: support schema odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/write/impl/batch/TableBatchWriteSessionImpl.java (1 line): - line 302: // TODO: clean up odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/enviroment/EnvironmentSettings.java (1 line): - line 53: // TODO: Environment Credentials odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/UDTFTaskContextImpl.java (1 line): - line 362: // TODO: hack task index here odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/read/TableReadSessionBuilder.java (1 line): - line 71: * TODO: For nested column-pruning odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/account/AppStsRequestSigner.java (1 line): - line 54: // TODO: Case sensitive odps-sdk-impl/odps-udf-example/src/main/java/com/aliyun/odps/udf/example/weather/NetCdfExtractor.java (1 line): - line 65: // TODO: do type checking for all columns odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/tunnel/hasher/DefaultHashFactory.java (1 line): - line 480: // TODO: check overflow odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/Schema.java (1 line): - line 37: //TODO external schema not support yet odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/FileResource.java (1 line): - line 66: // TODO: replace with a static builder odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/Tenant.java (1 line): - line 135: // TODO: avoid multiple Gson instances odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/account/AppRequestSigner.java (1 line): - line 45: // TODO: Case sensitive odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/write/TableBatchWriteSession.java (1 line): - line 37: * TODO: commit with settings odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/VolumeResource.java (1 line): - line 21: // TODO: replace with a static builder odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/tunnel/HttpHeaders.java (1 line): - line 20: // TODO: merge to Headers odps-sdk-impl/odps-mapred-local/src/main/java/com/aliyun/odps/mapred/LocalJobRunner.java (1 line): - line 572: // FIXME: Support partition odps-sdk/odps-sdk-udf/src/main/java/com/aliyun/odps/udf/OutputFormat.java (1 line): - line 11: * TODO: see if we can remove this odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/utils/CSVRecordParser.java (1 line): - line 79: // TODO: timezone odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/sqa/commandapi/WhoamiCommand.java (1 line): - line 82: // TODO: support specify tunnel quota from ..? odps-sdk-impl/odps-udf-local/src/main/java/com/aliyun/odps/udf/local/runner/ExtractorRunner.java (1 line): - line 65: // TODO: support feeding format of :: odps-examples/tunnel-examples/src/main/java/SchemaEvolution/StreamUploadIfSchemaEvolutionExpectedSample.java (1 line): - line 99: // TODO: rebuildSessionUtilSchemaEvolution(odps, null); odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/write/impl/batch/ArrowWriterImpl.java (1 line): - line 200: // TODO: compress odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/sqa/SQLExecutorImpl.java (1 line): - line 233: // TODO: support specify tunnel quota name odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/Sessions.java (1 line): - line 34: // TODO add limit for list api, there is no need to do it currently odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/streaming/io/RecordInputWriter.java (1 line): - line 39: // FIXME key-value separator VS field separator odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/streaming/io/RecordOutputReader.java (1 line): - line 102: // FIXME what if reduce output line has different num of fields than output table? odps-sdk/odps-sdk-udf/src/main/java/com/aliyun/odps/udf/BridgeStorageHandler.java (1 line): - line 5: * TODO: see if we can remove bridged version of inputformat and outputformat, then we can odps-sdk/odps-sdk-table-api/src/main/java/com/aliyun/odps/table/metrics/Metrics.java (1 line): - line 61: // TODO: toString odps-sdk/odps-sdk-commons/src/main/java/com/aliyun/odps/data/OdpsTypeTransformer.java (1 line): - line 432: //TODO remove this odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/tunnel/hasher/LegacyHashFactory.java (1 line): - line 429: // TODO: check overflow odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/streaming/PathFinder.java (1 line): - line 81: if (f.isFile()/* FIXME && FileUtil.canRead(f)*/) { odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/commons/transport/Headers.java (1 line): - line 39: // TODO: the last modified header used by volume is "Last_Modified", hard coded in the server odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/LotMapperUDTF.java (1 line): - line 357: // TODO Auto-generated catch block odps-examples/tunnel-examples/src/main/java/SchemaEvolution/StreamUploadIfSchemaEvolutionUnexpectedSample.java (1 line): - line 105: // FIXME: User intervention is actually required here, and the sample code demonstrates how to resume writing odps-sdk/odps-sdk-mapred/src/main/java/com/aliyun/odps/pipeline/Pipeline.java (1 line): - line 693: // TODO check the previous node odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/tunnel/io/ProtobufRecordPack.java (1 line): - line 156: // FIXME: 返回的并不是 probuf 的 stream，而是 protobuf 输出的那个缓冲区 odps-sdk-impl/odps-graph-local/src/main/java/com/aliyun/odps/graph/local/LocalGraphJobRunner.java (1 line): - line 333: // FIXME: Support partition odps-sdk/odps-lot-proto/lot/expression.proto (1 line): - line 57: //TODO: add other properties. odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/tunnel/io/streaming/utils/HashGenerator.java (1 line): - line 4: // TODO 替换为与SQL一样的hash函数 odps-sdk/odps-sdk-commons/src/main/java/com/aliyun/odps/io/Text.java (1 line): - line 138: // FIXME: should >= ? odps-sdk/odps-sdk-core/src/main/java/com/aliyun/odps/commons/util/ArrowUtils.java (1 line): - line 152: //TODO: 8 bytes => 12 bytes