Java 类org.apache.hadoop.mapreduce.QueueAclsInfo 实例源码

项目：pentaho-hadoop-shims 文件：ConfigurationProxyV2Test.java

@Test(expected = YarnQueueAclsException.class)
public void testSubmitWhenUserHasNoPermissionsToSubmitJobInQueueShouldRaiseYarnQueueAclsException() throws IOException, InterruptedException, ClassNotFoundException{
  Mockito.spy( YarnQueueAclsVerifier.class );
  ConfigurationProxyV2 configurationProxyV2 = Mockito.mock( ConfigurationProxyV2.class );
  Cluster cluster = Mockito.mock( Cluster.class );
  Job job = Mockito.mock( Job.class );

  Mockito.when( configurationProxyV2.getJob() ).thenReturn( job );
  Mockito.when( configurationProxyV2.createClusterDescription( Mockito.any( Configuration.class ) ) ).thenReturn( cluster );
  Mockito.when( configurationProxyV2.submit() ).thenCallRealMethod();
  Mockito.when( cluster.getQueueAclsForCurrentUser() ).thenReturn( new QueueAclsInfo[]{
    new QueueAclsInfo( StringUtils.EMPTY, new String[]{
      "ANOTHER_RIGHTS"
    } ),
    new QueueAclsInfo( StringUtils.EMPTY, new String[]{})
  });

  configurationProxyV2.submit();
}

项目：pentaho-hadoop-shims 文件：ConfigurationProxyV2Test.java

@Test
public void testSubmitWhenUserHasPermissionsToSubmitJobInQueueShouldExecuteSuccessfully() throws IOException, InterruptedException, ClassNotFoundException{
  Mockito.spy( YarnQueueAclsVerifier.class );
  ConfigurationProxyV2 configurationProxyV2 = Mockito.mock( ConfigurationProxyV2.class );
  Cluster cluster = Mockito.mock( Cluster.class );
  Job job = Mockito.mock( Job.class );

  Mockito.when( configurationProxyV2.getJob() ).thenReturn( job );
  Mockito.when( configurationProxyV2.createClusterDescription( Mockito.any( Configuration.class ) ) ).thenReturn( cluster );
  Mockito.when( configurationProxyV2.submit() ).thenCallRealMethod();
  Mockito.when( cluster.getQueueAclsForCurrentUser() ).thenReturn( new QueueAclsInfo[]{
    new QueueAclsInfo( StringUtils.EMPTY, new String[]{
      "SUBMIT_APPLICATIONS"
    } ),
    new QueueAclsInfo( StringUtils.EMPTY, new String[]{})
  });

  Assert.assertNotNull( configurationProxyV2.submit() );
}

项目：hadoop 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：aliyun-oss-hadoop-fs 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：big-c 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：hadoop-plus 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：FlexMap 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：hops 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：hadoop-TCP 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：hardfs 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：hadoop-on-lustre2 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(client
      .getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：pentaho-hadoop-shims 文件：YarnQueueAclsVerifierTest.java

@Test
public void testVerifyWhenUserHasNoPermissionsForSubmitInAnyQueueShouldReturnFalse() throws Exception {
  assertFalse( YarnQueueAclsVerifier.verify( new QueueAclsInfo[] {
    new QueueAclsInfo( StringUtils.EMPTY, new String[] {
      "ANOTHER_RIGHTS"
    } ),
    new QueueAclsInfo( StringUtils.EMPTY, new String[] {} )
  } ) );
}

项目：pentaho-hadoop-shims 文件：YarnQueueAclsVerifierTest.java

@Test
public void testVerifyWhenUserHasPermissionsForSubmitInAnyQueueShouldReturnTrue() throws Exception {
  assertTrue( YarnQueueAclsVerifier.verify( new QueueAclsInfo[] {
    new QueueAclsInfo( StringUtils.EMPTY, new String[] {
      "SUBMIT_APPLICATIONS"
    } ),
    new QueueAclsInfo( StringUtils.EMPTY, new String[] {} )
  } ) );
}

项目：incubator-tez 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(
        client.getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：tez 文件：ResourceMgrDelegate.java

public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnQueueUserAclsInfo(
        client.getQueueAclsInfo());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}

项目：big_data 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException, InterruptedException {
    return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：hadoop 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：aliyun-oss-hadoop-fs 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：big-c 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：hadoop-EAR 文件：MockSimulatorJobTracker.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();

}

项目：hadoop-plus 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：FlexMap 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：ignite 文件：HadoopClientProtocol.java

/** {@inheritDoc} */
@Override public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException, InterruptedException {
    return new QueueAclsInfo[0];
}

项目：hops 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：hadoop-TCP 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：hardfs 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：hadoop-on-lustre2 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：RDFS 文件：MockSimulatorJobTracker.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();

}

项目：pentaho-hadoop-shims 文件：YarnQueueAclsVerifier.java

public static boolean verify( QueueAclsInfo[] queueAclsInfos ) throws IOException, InterruptedException {
  return queueAclsInfos != null && Arrays.stream( queueAclsInfos ).map( QueueAclsInfo::getOperations )
    .flatMap( Arrays::stream ).anyMatch( Predicate.isEqual( QueueACL.SUBMIT_APPLICATIONS.toString() ) );
}

项目：incubator-tez 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：mapreduce-fork 文件：MockSimulatorJobTracker.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();

}

项目：tez 文件：YARNRunner.java

@Override
public QueueAclsInfo[] getQueueAclsForCurrentUser() throws IOException,
    InterruptedException {
  return resMgrDelegate.getQueueAclsForCurrentUser();
}

项目：hadoop 文件：ClientProtocol.java

/**
 * Gets the Queue ACLs for current user
 * @return array of QueueAclsInfo object for current user.
 * @throws IOException
 */
public QueueAclsInfo[] getQueueAclsForCurrentUser() 
throws IOException, InterruptedException;

项目：aliyun-oss-hadoop-fs 文件：ClientProtocol.java

/**
 * Gets the Queue ACLs for current user
 * @return array of QueueAclsInfo object for current user.
 * @throws IOException
 */
public QueueAclsInfo[] getQueueAclsForCurrentUser() 
throws IOException, InterruptedException;

项目：big-c 文件：ClientProtocol.java

/**
 * Gets the Queue ACLs for current user
 * @return array of QueueAclsInfo object for current user.
 * @throws IOException
 */
public QueueAclsInfo[] getQueueAclsForCurrentUser() 
throws IOException, InterruptedException;

项目：hadoop-2.6.0-cdh5.4.3 文件：ClientProtocol.java

/**
 * Gets the Queue ACLs for current user
 * @return array of QueueAclsInfo object for current user.
 * @throws IOException
 */
public QueueAclsInfo[] getQueueAclsForCurrentUser() 
throws IOException, InterruptedException;

项目：hadoop-plus 文件：ClientProtocol.java

/**
 * Gets the Queue ACLs for current user
 * @return array of QueueAclsInfo object for current user.
 * @throws IOException
 */
public QueueAclsInfo[] getQueueAclsForCurrentUser() 
throws IOException, InterruptedException;

项目：FlexMap 文件：ClientProtocol.java

/**
 * Gets the Queue ACLs for current user
 * @return array of QueueAclsInfo object for current user.
 * @throws IOException
 */
public QueueAclsInfo[] getQueueAclsForCurrentUser() 
throws IOException, InterruptedException;