Path Lines of Code api/src/main/java/org/apache/livy/Job.java 5 api/src/main/java/org/apache/livy/JobContext.java 20 api/src/main/java/org/apache/livy/JobHandle.java 22 api/src/main/java/org/apache/livy/LivyClient.java 13 api/src/main/java/org/apache/livy/LivyClientBuilder.java 116 api/src/main/java/org/apache/livy/LivyClientFactory.java 8 api/src/main/java/org/apache/livy/annotations/Private.java 7 api/src/main/java/org/apache/livy/package-info.java 1 client-common/src/main/java/org/apache/livy/client/common/AbstractJobHandle.java 67 client-common/src/main/java/org/apache/livy/client/common/BufferUtils.java 17 client-common/src/main/java/org/apache/livy/client/common/ClientConf.java 205 client-common/src/main/java/org/apache/livy/client/common/HttpMessages.java 119 client-common/src/main/java/org/apache/livy/client/common/Serializer.java 54 client-common/src/main/java/org/apache/livy/client/common/TestUtils.java 41 client-http/src/main/java/org/apache/livy/client/http/HttpClient.java 138 client-http/src/main/java/org/apache/livy/client/http/HttpClientFactory.java 14 client-http/src/main/java/org/apache/livy/client/http/HttpConf.java 84 client-http/src/main/java/org/apache/livy/client/http/JobHandleImpl.java 211 client-http/src/main/java/org/apache/livy/client/http/LivyConnection.java 190 core/src/main/scala/org/apache/livy/EOLUtils.scala 59 core/src/main/scala/org/apache/livy/Logging.scala 32 core/src/main/scala/org/apache/livy/Utils.scala 77 core/src/main/scala/org/apache/livy/msgs.scala 36 core/src/main/scala/org/apache/livy/sessions/Kind.scala 35 core/src/main/scala/org/apache/livy/sessions/SessionState.scala 40 dev/merge_livy_pr.py 310 dev/third-party-file.ftl 51 python-api/MANIFEST.in 3 python-api/setup.cfg 6 python-api/setup.py 38 python-api/src/main/python/livy/__init__.py 1 python-api/src/main/python/livy/client.py 183 python-api/src/main/python/livy/job_context.py 38 python-api/src/main/python/livy/job_handle.py 172 repl/scala-2.11/src/main/scala/org/apache/livy/repl/SparkInterpreter.scala 91 repl/scala-2.12/src/main/scala/org/apache/livy/repl/SparkInterpreter.scala 92 repl/src/main/resources/fake_shell.py 533 repl/src/main/scala/org/apache/livy/repl/AbstractSparkInterpreter.scala 262 repl/src/main/scala/org/apache/livy/repl/BypassPySparkJob.scala 16 repl/src/main/scala/org/apache/livy/repl/Interpreter.scala 21 repl/src/main/scala/org/apache/livy/repl/ProcessInterpreter.scala 84 repl/src/main/scala/org/apache/livy/repl/PySparkJobProcessor.scala 7 repl/src/main/scala/org/apache/livy/repl/PythonInterpreter.scala 255 repl/src/main/scala/org/apache/livy/repl/ReplDriver.scala 110 repl/src/main/scala/org/apache/livy/repl/SQLInterpreter.scala 58 repl/src/main/scala/org/apache/livy/repl/Session.scala 274 repl/src/main/scala/org/apache/livy/repl/SparkRInterpreter.scala 283 repl/src/main/scala/org/apache/livy/repl/package.scala 9 rsc/src/main/java/org/apache/livy/rsc/BaseProtocol.java 171 rsc/src/main/java/org/apache/livy/rsc/BypassJobStatus.java 15 rsc/src/main/java/org/apache/livy/rsc/ContextInfo.java 13 rsc/src/main/java/org/apache/livy/rsc/ContextLauncher.java 360 rsc/src/main/java/org/apache/livy/rsc/DriverProcessInfo.java 16 rsc/src/main/java/org/apache/livy/rsc/FutureListener.java 5 rsc/src/main/java/org/apache/livy/rsc/JobHandleImpl.java 67 rsc/src/main/java/org/apache/livy/rsc/PingJob.java 9 rsc/src/main/java/org/apache/livy/rsc/RSCClient.java 344 rsc/src/main/java/org/apache/livy/rsc/RSCClientFactory.java 76 rsc/src/main/java/org/apache/livy/rsc/RSCConf.java 151 rsc/src/main/java/org/apache/livy/rsc/ReplJobResults.java 11 rsc/src/main/java/org/apache/livy/rsc/Utils.java 78 rsc/src/main/java/org/apache/livy/rsc/driver/AddFileJob.java 18 rsc/src/main/java/org/apache/livy/rsc/driver/AddJarJob.java 18 rsc/src/main/java/org/apache/livy/rsc/driver/BypassJob.java 27 rsc/src/main/java/org/apache/livy/rsc/driver/BypassJobWrapper.java 61 rsc/src/main/java/org/apache/livy/rsc/driver/JobContextImpl.java 109 rsc/src/main/java/org/apache/livy/rsc/driver/JobWrapper.java 68 rsc/src/main/java/org/apache/livy/rsc/driver/MutableClassLoader.java 12 rsc/src/main/java/org/apache/livy/rsc/driver/RSCDriver.java 404 rsc/src/main/java/org/apache/livy/rsc/driver/RSCDriverBootstrapper.java 57 rsc/src/main/java/org/apache/livy/rsc/driver/SparkEntries.java 107 rsc/src/main/java/org/apache/livy/rsc/driver/Statement.java 37 rsc/src/main/java/org/apache/livy/rsc/driver/StatementState.java 55 rsc/src/main/java/org/apache/livy/rsc/package-info.java 1 rsc/src/main/java/org/apache/livy/rsc/rpc/KryoMessageCodec.java 106 rsc/src/main/java/org/apache/livy/rsc/rpc/Rpc.java 499 rsc/src/main/java/org/apache/livy/rsc/rpc/RpcDispatcher.java 41 rsc/src/main/java/org/apache/livy/rsc/rpc/RpcException.java 6 rsc/src/main/java/org/apache/livy/rsc/rpc/RpcServer.java 261 rsc/src/main/java/org/apache/livy/rsc/rpc/SaslHandler.java 69 scala-api/src/main/scala/org/apache/livy/scalaapi/LivyScalaClient.scala 59 scala-api/src/main/scala/org/apache/livy/scalaapi/ScalaJobContext.scala 21 scala-api/src/main/scala/org/apache/livy/scalaapi/ScalaJobHandle.scala 83 scala-api/src/main/scala/org/apache/livy/scalaapi/package.scala 16 scalastyle.xml 96 server/src/main/resources/org/apache/livy/server/ui/static/css/livy-ui.css 29 server/src/main/resources/org/apache/livy/server/ui/static/html/batches-table.html 50 server/src/main/resources/org/apache/livy/server/ui/static/html/sessions-table.html 57 server/src/main/resources/org/apache/livy/server/ui/static/html/statements-table.html 63 server/src/main/resources/org/apache/livy/server/ui/static/js/all-sessions.js 63 server/src/main/resources/org/apache/livy/server/ui/static/js/livy-ui.js 99 server/src/main/resources/org/apache/livy/server/ui/static/js/session-log.js 56 server/src/main/resources/org/apache/livy/server/ui/static/js/session.js 116 server/src/main/scala/org/apache/livy/LivyConf.scala 303 server/src/main/scala/org/apache/livy/package.scala 49 server/src/main/scala/org/apache/livy/server/AccessFilter.scala 20 server/src/main/scala/org/apache/livy/server/AccessManager.scala 80 server/src/main/scala/org/apache/livy/server/ApiVersioningSupport.scala 33 server/src/main/scala/org/apache/livy/server/ApiVersions.scala 5 server/src/main/scala/org/apache/livy/server/CsrfFilter.scala 21 server/src/main/scala/org/apache/livy/server/JsonServlet.scala 93 server/src/main/scala/org/apache/livy/server/LivyServer.scala 336 server/src/main/scala/org/apache/livy/server/SecurityHeadersFilter.scala 28 server/src/main/scala/org/apache/livy/server/SessionServlet.scala 165 server/src/main/scala/org/apache/livy/server/ThriftServerFactory.scala 21 server/src/main/scala/org/apache/livy/server/WebServer.scala 87 server/src/main/scala/org/apache/livy/server/auth/LdapAuthenticationHandlerImpl.scala 160 server/src/main/scala/org/apache/livy/server/auth/LdapUtils.scala 44 server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala 160 server/src/main/scala/org/apache/livy/server/batch/BatchSessionServlet.scala 56 server/src/main/scala/org/apache/livy/server/batch/CreateBatchRequest.scala 36 server/src/main/scala/org/apache/livy/server/interactive/CreateInteractiveRequest.scala 39 server/src/main/scala/org/apache/livy/server/interactive/InteractiveSession.scala 600 server/src/main/scala/org/apache/livy/server/interactive/InteractiveSessionServlet.scala 237 server/src/main/scala/org/apache/livy/server/interactive/SessionHeartbeat.scala 70 server/src/main/scala/org/apache/livy/server/recovery/BlackholeStateStore.scala 9 server/src/main/scala/org/apache/livy/server/recovery/FileSystemStateStore.scala 121 server/src/main/scala/org/apache/livy/server/recovery/SessionStore.scala 45 server/src/main/scala/org/apache/livy/server/recovery/StateStore.scala 58 server/src/main/scala/org/apache/livy/server/recovery/ZooKeeperManager.scala 80 server/src/main/scala/org/apache/livy/server/recovery/ZooKeeperStateStore.scala 25 server/src/main/scala/org/apache/livy/server/ui/UIServlet.scala 125 server/src/main/scala/org/apache/livy/sessions/Session.scala 240 server/src/main/scala/org/apache/livy/sessions/SessionManager.scala 179 server/src/main/scala/org/apache/livy/utils/Clock.scala 13 server/src/main/scala/org/apache/livy/utils/LineBufferedProcess.scala 23 server/src/main/scala/org/apache/livy/utils/LineBufferedStream.scala 77 server/src/main/scala/org/apache/livy/utils/LivySparkUtils.scala 113 server/src/main/scala/org/apache/livy/utils/LivyUncaughtException.java 6 server/src/main/scala/org/apache/livy/utils/SparkApp.scala 73 server/src/main/scala/org/apache/livy/utils/SparkKubernetesApp.scala 723 server/src/main/scala/org/apache/livy/utils/SparkProcApp.scala 39 server/src/main/scala/org/apache/livy/utils/SparkProcessBuilder.scala 158 server/src/main/scala/org/apache/livy/utils/SparkYarnApp.scala 263 thriftserver/server/src/main/resources/org/apache/livy/server/ui/static/html/thrift-sessions-table.html 33 thriftserver/server/src/main/resources/org/apache/livy/server/ui/static/js/thrift-sessions.js 30 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyCLIService.scala 363 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyExecuteStatementOperation.scala 153 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyOperationManager.scala 240 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftServer.scala 105 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala 534 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/SessionInfo.scala 49 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/SessionStates.scala 7 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/ThriftServerAudit.scala 15 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/ThriftServerFactoryImpl.scala 26 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/ThriftService.scala 84 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/AuthBridgeServer.scala 204 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/AuthFactory.scala 143 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/AuthenticationProvider.scala 39 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/LdapAuthenticationProviderImpl.scala 42 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/LivyDelegationTokenSecretManager.scala 39 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/PlainSaslServer.scala 133 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/ldap/ChainFilter.scala 8 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/ldap/DirSearchFactory.scala 8 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/ldap/Filter.scala 6 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/ldap/LdapSearchFactory.scala 33 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/ldap/UserFilter.scala 21 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThreadPoolExecutorWithOomHook.scala 30 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThriftBinaryCLIService.scala 139 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThriftCLIService.scala 665 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThriftHttpCLIService.scala 154 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThriftHttpServlet.scala 352 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/GetCatalogsOperation.scala 32 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/GetColumnsOperation.scala 76 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/GetFunctionsOperation.scala 49 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/GetSchemasOperation.scala 40 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/GetTableTypesOperation.scala 34 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/GetTablesOperation.scala 47 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/GetTypeInfoOperation.scala 98 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/MetadataOperation.scala 25 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/Operation.scala 117 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/operation/SparkCatalogOperation.scala 43 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/rpc/RpcClient.scala 70 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/serde/ThriftResultSet.scala 96 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/types/DataTypeUtils.scala 37 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/types/Schema.scala 107 thriftserver/server/src/main/scala/org/apache/livy/thriftserver/ui/ThriftJsonServlet.scala 30 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/CatalogJobState.java 8 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/CleanupStatementJob.java 19 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java 337 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/DataType.java 15 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/FetchResultJob.java 36 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/FetchResultSchemaJob.java 19 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/GetColumnsJob.java 72 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/GetFunctionsJob.java 75 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/GetSchemasJob.java 30 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/GetTablesJob.java 70 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/RegisterSessionJob.java 17 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ResultSet.java 81 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ScalaIterator.java 20 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/SparkCatalogJob.java 53 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/SparkUtils.java 163 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/SqlJob.java 55 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/StatementState.java 14 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ThriftSessionState.java 88 thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/UnregisterSessionJob.java 20