kernel/src/main/scala/org/apache/toree/kernel/api/Kernel.scala (4 lines): - line 361: // TODO: Think of a better way to test without exposing this - line 374: // TODO: Think of a better way to test without exposing this - line 378: // TODO: Inject stream redirect headers in Spark dynamically - line 395: // TODO: Exposed for testing purposes. scala-interpreter/src/main/scala-2.12/org/apache/toree/kernel/interpreter/scala/ScalaInterpreterSpecific.scala (3 lines): - line 199: // TODO: Get this API method changed back to public in Apache Spark - line 430: // TODO: This wrapper is not needed when just getting compile - line 448: * TODO: Revisit this once Scala 2.12 is released. kernel/src/main/scala/org/apache/toree/boot/layer/HookInitialization.scala (3 lines): - line 73: // TODO: Signals are not a good way to handle this since JVM only has the - line 85: // TODO: Cancel group representing current code execution - line 112: // TODO: Cancel group representing current code execution scala-interpreter/src/main/scala/org/apache/toree/kernel/interpreter/scala/ScalaInterpreter.scala (3 lines): - line 169: // TODO: use SparkContext.setJobGroup to avoid killing all jobs - line 349: // TODO: Investigate why the cluster has to be initialized in the kernel - line 369: // TODO: This only adds the context to the main interpreter AND kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/relay/KernelMessageRelay.scala (3 lines): - line 112: // TODO: How to restore this when the actor dies? - line 147: // TODO: Figure out what the failure message structure should be! - line 171: // TODO: Handle error case for mapTo and non-present onFailure client/src/main/scala/org/apache/toree/kernel/protocol/v5/client/Utilities.scala (2 lines): - line 59: // TODO Handle the case where there is no delimiter - line 66: // TODO: Investigate better solution than setting parentHeader to null for {} kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/CommOpenHandler.scala (2 lines): - line 77: // TODO: Should we be checking the return values? Probably not. - line 86: // TODO: Determine proper response for a parse failure kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/kernel/Utilities.scala (2 lines): - line 57: // TODO Handle the case where there is no delimiter - line 63: // TODO: Investigate better solution than setting parentHeader to null for {} protocol/src/main/scala/org/apache/toree/kernel/protocol/v5/content/HistoryReply.scala (2 lines): - line 26: // TODO: This is really (String, String, String | (String, String)), look - line 27: // TODO: into writing implicits to handle tuples kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/CommCloseHandler.scala (2 lines): - line 73: // TODO: Should we be checking the return values? Probably not. - line 82: // TODO: Determine proper response for a parse failure kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/interpreter/tasks/ExecuteRequestTaskActor.scala (2 lines): - line 70: // TODO: Think of a cleaner wrapper to handle updating the Console - line 103: sender ! "Unknown message" // TODO: Provide a failure message type to be passed around? kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/CommMsgHandler.scala (2 lines): - line 73: // TODO: Should we be checking the return values? Probably not. - line 82: // TODO: Determine proper response for a parse failure kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala (2 lines): - line 173: // TODO: Move SparkIMain to private and insert in a different way - line 176: // TODO: Construct class server outside of SparkIMain sql-interpreter/src/main/scala/org/apache/toree/kernel/interpreter/sql/SqlService.scala (2 lines): - line 52: // TODO: There is an internal method used for show called showString that - line 57: // TODO: Provide some way to change the number of records shown kernel-api/src/main/scala/org/apache/toree/security/KernelSecurityManager.scala (2 lines): - line 83: // TODO: Investigate why the StackOverflowError occurs in IntelliJ without - line 95: // TODO: Investigate why the StackOverflowError occurs in IntelliJ without protocol/src/main/scala/org/apache/toree/kernel/protocol/v5/content/InspectRequest.scala (2 lines): - line 26: detail_level: Int // TODO: This is currently either 0 or 1... should we - line 27: // TODO: look into enforcing that in our schema? client/src/main/scala/org/apache/toree/kernel/protocol/v5/client/SparkKernelClient.scala (1 line): - line 126: // TODO: hide this? just heartbeat to see if kernel is reachable? protocol/src/main/scala/org/apache/toree/kernel/protocol/v5/package.scala (1 line): - line 66: // TODO: Split this into client/server socket types and move them to their kernel/src/main/scala/org/apache/toree/utils/MessageLogSupport.scala (1 line): - line 56: // TODO: Migrate this to a helper method in MessageType.Incoming kernel-api/src/main/scala/org/apache/toree/interpreter/package.scala (1 line): - line 20: // TODO: Deprecate and remove this package object as it is difficult to kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/dispatch/StatusDispatch.scala (1 line): - line 43: // TODO Determine if this should be null or an empty parent header kernel/src/main/scala/org/apache/toree/magic/builtin/BuiltinLoader.scala (1 line): - line 45: // TODO: Decide if this.getClass.getClassLoader should just be this kernel-api/src/main/scala/org/apache/toree/magic/InternalClassLoader.scala (1 line): - line 30: // TODO: Provides an exposed reference to the super loadClass to be stubbed protocol/src/main/scala/org/apache/toree/kernel/protocol/v5/KernelMessage.scala (1 line): - line 24: parentHeader: ParentHeader, // TODO: This can be an empty json object of {} kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/KernelInfoRequestHandler.scala (1 line): - line 48: // TODO could we use HeaderBuilder here? kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/interpreter/InterpreterActor.scala (1 line): - line 39: // TODO: Investigate restart sequence kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/kernel/socket/ZeromqKernelMessageSocket.scala (1 line): - line 54: ).takeRight(4) // TODO: This assumes NO extra buffers, refactor? kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/ExecuteRequestHandler.scala (1 line): - line 69: // TODO: Add support for error streams kernel/src/main/scala/org/apache/toree/boot/KernelBootstrap.scala (1 line): - line 59: // TODO: Investigate potential to initialize System out/err/in to capture kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/interpreter/tasks/IsCompleteTaskActor.scala (1 line): - line 39: sender ! "Unknown message" // TODO: Provide a failure message type to be passed around? kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/InputRequestReplyHandler.scala (1 line): - line 44: // TODO: Is there a better way than storing actor refs? client/src/main/scala/org/apache/toree/kernel/protocol/v5/client/socket/IOPubClient.scala (1 line): - line 182: // TODO: Validate incoming message signature kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/interpreter/tasks/CodeCompleteTaskActor.scala (1 line): - line 39: sender ! "Unknown message" // TODO: Provide a failure message type to be passed around? communication/src/main/scala/org/apache/toree/communication/security/SignatureManagerActor.scala (1 line): - line 79: // TODO: Proper error handling for possible exception from mapTo kernel/src/main/scala/org/apache/toree/boot/layer/HandlerInitialization.scala (1 line): - line 142: // TODO: Figure out how to pass variable number of arguments to actor protocol/src/main/scala/org/apache/toree/kernel/protocol/v5/content/package.scala (1 line): - line 24: // TODO: Is there a way to wrap the Option arguments in Some(...)? protocol/src/main/scala/org/apache/toree/comm/CommManager.scala (1 line): - line 50: // TODO: This is potentially bad design considering appending methods to client/src/main/scala/org/apache/toree/kernel/protocol/v5/client/socket/ShellClient.scala (1 line): - line 68: // TODO: Validate incoming message signature kernel-api/src/main/scala/org/apache/toree/interpreter/ExecuteFailure.scala (1 line): - line 41: // TODO: Replace with object? kernel-api/src/main/scala/org/apache/toree/interpreter/broker/BrokerProcess.scala (1 line): - line 185: // TODO: Figure out how to dynamically update the output stream used