本文整理了Java中org.apache.hadoop.hdfs.server.datanode.DataNode.shouldRun()方法的一些代码示例，展示了DataNode.shouldRun()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。DataNode.shouldRun()方法的具体详情如下：
包路径：org.apache.hadoop.hdfs.server.datanode.DataNode
类名称：DataNode
方法名：shouldRun

DataNode.shouldRun介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

private boolean shouldRun() {
 return shouldServiceRun && dn.shouldRun();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

private boolean shouldRun() {
 return shouldServiceRun && dn.shouldRun();
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

private boolean shouldRun() {
 return shouldServiceRun && dn.shouldRun();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

@Before
public void setUp() throws IOException {
 mockDnConf = mock(DNConf.class);
 doReturn(VersionInfo.getVersion()).when(mockDnConf).getMinimumNameNodeVersion();
 
 DataNode mockDN = mock(DataNode.class);
 doReturn(true).when(mockDN).shouldRun();
 doReturn(mockDnConf).when(mockDN).getDnConf();
 
 BPOfferService mockBPOS = mock(BPOfferService.class);
 doReturn(mockDN).when(mockBPOS).getDataNode();
 
 actor = new BPServiceActor(INVALID_ADDR, mockBPOS);
 fakeNsInfo = mock(NamespaceInfo.class);
 // Return a a good software version.
 doReturn(VersionInfo.getVersion()).when(fakeNsInfo).getSoftwareVersion();
 // Return a good layout version for now.
 doReturn(HdfsConstants.NAMENODE_LAYOUT_VERSION).when(fakeNsInfo)
   .getLayoutVersion();
 
 DatanodeProtocolClientSideTranslatorPB fakeDnProt = 
   mock(DatanodeProtocolClientSideTranslatorPB.class);
 when(fakeDnProt.versionRequest()).thenReturn(fakeNsInfo);
 actor.setNameNode(fakeDnProt);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

@Before
public void setupMocks() throws Exception {
 mockNN1 = setupNNMock(0);
 mockNN2 = setupNNMock(1);
 // Set up a mock DN with the bare-bones configuration
 // objects, etc.
 mockDn = Mockito.mock(DataNode.class);
 Mockito.doReturn(true).when(mockDn).shouldRun();
 Configuration conf = new Configuration();
 File dnDataDir = new File(new File(TEST_BUILD_DATA, "dfs"), "data");
 conf.set(DFS_DATANODE_DATA_DIR_KEY, dnDataDir.toURI().toString());
 Mockito.doReturn(conf).when(mockDn).getConf();
 Mockito.doReturn(new DNConf(conf)).when(mockDn).getDnConf();
 Mockito.doReturn(DataNodeMetrics.create(conf, "fake dn"))
 .when(mockDn).getMetrics();
 // Set up a simulated dataset with our fake BP
 mockFSDataset = Mockito.spy(new SimulatedFSDataset(null, conf));
 mockFSDataset.addBlockPool(FAKE_BPID, conf);
 // Wire the dataset to the DN.
 Mockito.doReturn(mockFSDataset).when(mockDn).getFSDataset();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

public void testBPInitErrorHandling() throws Exception {
 final DataNode mockDn = Mockito.mock(DataNode.class);
 Mockito.doReturn(true).when(mockDn).shouldRun();
 Configuration conf = new Configuration();
 File dnDataDir = new File(