drill
[DRILL-7191 / DRILL-7026]: RM state blob persistence in Zookeeper and Integration of Distributed queue configuration with Planner
#1762
Open

Overview
Commits
7
Changes
View On GitHub
  • contrib
    • native/client/src/protobuf
      • File
        BitControl.pb.cc
      • File
        BitControl.pb.h
      • File
        UserBitShared.pb.cc
      • File
        UserBitShared.pb.h
    • storage-kafka/src/test/java/org/apache/drill/exec/store/kafka
      • File
        KafkaFilterPushdownTest.java
  • drill-yarn/src
    • main/java/org/apache/drill/yarn/zk
      • File
        ZKClusterCoordinator.java
      • File
        ZKRegistry.java
    • test/java/org/apache/drill/yarn/zk
      • File
        TestZkRegistry.java
  • exec
    • java-exec/src
      • main
        • java/org/apache/drill
          • common
            • File
              DrillNode.java
          • exec
            • File
              ExecConstants.java
            • coord
              • File
                ClusterCoordinator.java
              • local
                • File
                  LocalClusterCoordinator.java
              • zk
                • File
                  ZKClusterCoordinator.java
                • File
                  ZKRegistrationHandle.java
                • File
                  ZookeeperClient.java
            • ops
              • File
                OpProfileDef.java
              • File
                OperatorContextImpl.java
              • File
                OperatorStats.java
              • File
                QueryContext.java
            • physical
              • base
                • File
                  AbstractGroupScan.java
              • impl
                • File
                  BaseRootExec.java
            • planner
              • cost
                • File
                  NodeResource.java
              • fragment
                • File
                  DefaultParallelizer.java
                • File
                  DistributedQueueParallelizer.java
                • File
                  Fragment.java
                • File
                  Materializer.java
                • File
                  MemoryCalculator.java
                • File
                  QueryParallelizer.java
                • File
                  QueueQueryParallelizer.java
                • File
                  SimpleParallelizer.java
                • File
                  Wrapper.java
                • File
                  ZKQueueParallelizer.java
                • contrib
                  • File
                    SplittingParallelizer.java
              • sql
                • File
                  DirectPlan.java
                • handlers
                  • File
                    ShowFilesHandler.java
            • resourcemgr
              • File
                NodeResources.java
              • config
                • File
                  QueryQueueConfigImpl.java
                • File
                  ResourcePool.java
                • File
                  ResourcePoolImpl.java
                • File
                  ResourcePoolTree.java
                • File
                  ResourcePoolTreeImpl.java
                • selectionpolicy
                  • File
                    BestFitQueueSelection.java
                  • File
                    DefaultQueueSelection.java
                  • File
                    RandomQueueSelection.java
              • exception
                • File
                  QueueWaitTimeoutExpired.java
              • rmblobmgr
                • File
                  RMBlobStoreManager.java
                • File
                  RMConsistentBlobStoreManager.java
                • exception
                  • File
                    LeaderChangeException.java
                  • File
                    RMBlobUpdateException.java
                  • File
                    ResourceUnavailableException.java
                • rmblob
                  • File
                    AbstractRMStateBlob.java
                  • File
                    ClusterStateBlob.java
                  • File
                    ForemanQueueUsageBlob.java
                  • File
                    ForemanResourceUsage.java
                  • File
                    QueueLeadershipBlob.java
                  • File
                    RMStateBlob.java
            • rpc/user
              • File
                UserSession.java
            • server
              • File
                Drillbit.java
              • File
                DrillbitContext.java
            • store/sys
              • File
                PersistentStoreConfig.java
              • File
                PersistentStoreMode.java
              • store
                • File
                  ZookeeperPersistentStore.java
                • File
                  ZookeeperTransactionalPersistenceStore.java
                • provider
                  • File
                    ZookeeperPersistentStoreProvider.java
            • util/memory
              • File
                DefaultMemoryAllocationUtilities.java
              • File
                MemoryAllocationUtilities.java
              • File
                ZKQueueMemoryAllocationUtilities.java
            • work
              • File
                WorkManager.java
              • foreman
                • File
                  DrillbitStatusListener.java
                • File
                  Foreman.java
                • File
                  QueryManager.java
                • rm
                  • File
                    DefaultResourceManager.java
                  • File
                    DistributedResourceManager.java
                  • File
                    DynamicResourceManager.java
                  • File
                    QueryResourceAllocator.java
                  • File
                    QueryResourceManager.java
                  • File
                    ResourceManager.java
                  • File
                    ResourceManagerBuilder.java
                  • File
                    ThrottledResourceManager.java
              • fragment
                • File
                  FragmentExecutor.java
              • user
                • File
                  PlanSplitter.java
        • resources
          • File
            drill-module.conf
      • test/java/org/apache/drill
        • File
          PlanTestBase.java
        • exec
          • memory
            • File
              TestAllocators.java
          • physical/impl
            • File
              TestLocalExchange.java
            • partitionsender
              • File
                TestPartitionSender.java
            • xsort/managed
              • File
                TestExternalSortInternals.java
          • planner
            • File
              PhysicalPlanReaderTestFactory.java
            • rm
              • File
                TestMemoryCalculator.java
          • pop
            • File
              TestFragmentChecker.java
          • record
            • File
              TestRecordIterator.java
          • resourcemgr
            • File
              RMBlobManagerTest.java
            • File
              TestDistributedQueryRM.java
            • File
              TestE2EWithDistributedRM.java
            • File
              TestRMConfigLoad.java
          • store/dfs
            • File
              TestDrillFileSystem.java
          • util
            • File
              TestQueryMemoryAlloc.java
        • test
          • File
            ExampleTest.java
          • File
            OperatorFixture.java
    • memory/base/src/main/java/org/apache/drill/exec/memory
      • File
        Accountant.java
  • protocol/src/main
    • java/org/apache/drill/exec/proto
      • File
        BitControl.java
      • File
        SchemaBitControl.java
      • File
        SchemaUserBitShared.java
      • File
        UserBitShared.java
      • beans
        • File
          OperatorProfile.java
        • File
          PlanFragment.java
    • protobuf
      • File
        BitControl.proto
      • File
        UserBitShared.proto

Loading comments...