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,new String[]{
      "SUBMIT_APPLICATIONS"
    } ),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 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 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;