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

Open

Overview Commits Changes View On GitHub

Files

108 file(s)

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

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

Files

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

Open