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

QueryInterruptedException.getErrorClass介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-druid

private static String getErrorClassFromThrowable(Throwable e)
{
 if (e instanceof QueryInterruptedException) {
  return ((QueryInterruptedException) e).getErrorClass();
 } else if (e != null) {
  return e.getClass().getName();
 } else {
  return null;
 }
}

代码示例来源：origin: apache/incubator-druid

new QueryInterruptedException(new QueryInterruptedException(new CancellationException())).getErrorClass()
);
Assert.assertEquals(
  "java.util.concurrent.CancellationException",
  new QueryInterruptedException(new CancellationException()).getErrorClass()
);
Assert.assertEquals(
  "java.lang.InterruptedException",
  new QueryInterruptedException(new InterruptedException()).getErrorClass()
);
Assert.assertEquals(
  "java.util.concurrent.TimeoutException",
  new QueryInterruptedException(new TimeoutException()).getErrorClass()
);
Assert.assertEquals(
  "org.apache.druid.query.ResourceLimitExceededException",
  new QueryInterruptedException(new ResourceLimitExceededException("too many!")).getErrorClass()
);
Assert.assertEquals(
  null,
  new QueryInterruptedException(null).getErrorClass()
);
Assert.assertEquals(
  "org.apache.druid.java.util.common.ISE",
  new QueryInterruptedException(new ISE("Something bad!")).getErrorClass()
);
Assert.assertEquals(
  "org.apache.druid.java.util.common.ISE",
  new QueryInterruptedException(new QueryInterruptedException(new ISE("Something bad!"))).getErrorClass()

代码示例来源：origin: apache/incubator-druid

@Test
public void testResourceLimitExceeded() throws Exception
{
 final QueryInterruptedException exception = doPost(
   new SqlQuery(
     "SELECT DISTINCT dim1 FROM foo",
     ResultFormat.OBJECT,
     false,
     ImmutableMap.of("maxMergingDictionarySize", 1)
   )
 ).lhs;
 Assert.assertNotNull(exception);
 Assert.assertEquals(exception.getErrorCode(), QueryInterruptedException.RESOURCE_LIMIT_EXCEEDED);
 Assert.assertEquals(exception.getErrorClass(), ResourceLimitExceededException.class.getName());
 checkSqlRequestLog(false);
}

代码示例来源：origin: apache/incubator-druid

@Test
public void testCannotConvert() throws Exception
{
 // SELECT + ORDER unsupported
 final QueryInterruptedException exception = doPost(
   new SqlQuery("SELECT dim1 FROM druid.foo ORDER BY dim1", ResultFormat.OBJECT, false, null)
 ).lhs;
 Assert.assertNotNull(exception);
 Assert.assertEquals(QueryInterruptedException.UNKNOWN_EXCEPTION, exception.getErrorCode());
 Assert.assertEquals(ISE.class.getName(), exception.getErrorClass());
 Assert.assertTrue(
   exception.getMessage()
        .contains("Cannot build plan for query: SELECT dim1 FROM druid.foo ORDER BY dim1")
 );
 checkSqlRequestLog(false);
}

代码示例来源：origin: apache/incubator-druid

@Test
public void testCannotValidate() throws Exception
{
 final QueryInterruptedException exception = doPost(
   new SqlQuery(
     "SELECT dim4 FROM druid.foo",
     ResultFormat.OBJECT,
     false,
     null
   )
 ).lhs;
 Assert.assertNotNull(exception);
 Assert.assertEquals(QueryInterruptedException.UNKNOWN_EXCEPTION, exception.getErrorCode());
 Assert.assertEquals(ValidationException.class.getName(), exception.getErrorClass());
 Assert.assertTrue(exception.getMessage().contains("Column 'dim4' not found in any table"));
 checkSqlRequestLog(false);
}

代码示例来源：origin: apache/incubator-druid

Assert.assertEquals(
  "java.util.concurrent.CancellationException",
  roundTrip(new QueryInterruptedException(new QueryInterruptedException(new CancellationException()))).getErrorClass()
);
Assert.assertEquals(
Assert.assertEquals(
  "java.util.concurrent.CancellationException",
  roundTrip(new QueryInterruptedException(new CancellationException())).getErrorClass()
);
Assert.assertEquals(
  "java.lang.InterruptedException",
  roundTrip(new QueryInterruptedException(new InterruptedException())).getErrorClass()
);
Assert.assertEquals(
  "java.util.concurrent.TimeoutException",
  roundTrip(new QueryInterruptedException(new TimeoutException())).getErrorClass()
);
Assert.assertEquals(
  null,
  roundTrip(new QueryInterruptedException(null)).getErrorClass()
);
Assert.assertEquals(
  "org.apache.druid.java.util.common.ISE",
  roundTrip(new QueryInterruptedException(new ISE("Something bad!"))).getErrorClass()
);
Assert.assertEquals(
  "org.apache.druid.java.util.common.ISE",
  roundTrip(new QueryInterruptedException(new QueryInterruptedException(new ISE("Something bad!")))).getErrorClass()

代码示例来源：origin: org.apache.druid/druid-processing

private static String getErrorClassFromThrowable(Throwable e)
{
 if (e instanceof QueryInterruptedException) {
  return ((QueryInterruptedException) e).getErrorClass();
 } else if (e != null) {
  return e.getClass().getName();
 } else {
  return null;
 }
}