org.apache.tajo.annotation.Nullable.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(151)

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

Nullable.<init>介绍

暂无

代码示例

代码示例来源:origin: apache/tajo

public NodeStatusEvent(int workerId, int runningTaskNum, int runningQMNum,
            NodeResource available, @Nullable NodeResource total) {
 super(workerId, NodeEventType.STATE_UPDATE);
 this.runningTaskNum = runningTaskNum;
 this.runningQMNum = runningQMNum;
 this.available = available;
 this.total = total;
}

代码示例来源:origin: apache/tajo

public TableDesc(String tableName, @Nullable Schema schema, TableMeta meta,
         @Nullable URI uri, boolean external) {
 this.tableName = tableName;
 this.schema = schema;
 this.meta = meta;
 this.uri = uri;
 this.external = external;
}

代码示例来源:origin: apache/tajo

/**
 * Get a list of table names.
 *
 * @param databaseName The database name to show all tables. This name is case sensitive.
 *                     If it is null, this method will show all tables
 *                     in the current database of this session.
 */
List<String> getTableList(@Nullable final String databaseName);

代码示例来源:origin: org.apache.tajo/tajo-catalog-common

public TableDesc(String tableName, @Nullable Schema schema, TableMeta meta,
         @Nullable URI uri, boolean external) {
 this.tableName = tableName;
 this.schema = schema;
 this.meta = meta;
 this.uri = uri;
 this.external = external;
}

代码示例来源:origin: apache/tajo

@Override
public @Nullable V getParent(V block, int idx) {
 if (directedEdges.containsKey(block)) {
  int i = 0;
  for (Map.Entry<V, E> entry: directedEdges.get(block).entrySet()) {
   if (idx == i++) {
    return entry.getKey();
   }
  }
 }
 return null;
}

代码示例来源:origin: org.apache.tajo/tajo-common

@Override
public @Nullable V getParent(V block, int idx) {
 if (directedEdges.containsKey(block)) {
  int i = 0;
  for (Map.Entry<V, E> entry: directedEdges.get(block).entrySet()) {
   if (idx == i++) {
    return entry.getKey();
   }
  }
 }
 return null;
}

代码示例来源:origin: org.apache.tajo/tajo-common

@Override
public @Nullable E getEdge(V tail, V head) {
 if (hasEdge(tail, head)) {
  return directedEdges.get(tail).get(head);
 } else {
  return null;
 }
}

代码示例来源:origin: org.apache.tajo/tajo-common

@Override
public @Nullable
E getReverseEdge(V head, V tail) {
 if (hasReversedEdge(head, tail)) {
  return reversedEdges.get(head).get(tail);
 } else {
  return null;
 }
}

代码示例来源:origin: org.apache.tajo/tajo-client

@Override
public TableDesc createExternalTable(String tableName, @Nullable Schema schema, URI path, TableMeta meta)
  throws DuplicateTableException, UnavailableTableLocationException, InsufficientPrivilegeException {
 return createExternalTable(tableName, schema, path, meta, null);
}

代码示例来源:origin: org.apache.tajo/tajo-cli

public static Properties get(@Nullable Properties connParam) {
  Properties copy = connParam == null ? new Properties() : (Properties) connParam.clone();
  for (Map.Entry<String, String> entry : DEFAULT_PARAMS.entrySet()) {
   if (!copy.contains(entry.getKey())) {
    copy.setProperty(entry.getKey(), entry.getValue());
   }
  }
  return copy;
 }
}

代码示例来源:origin: apache/tajo

@Override
public @Nullable
E getReverseEdge(V head, V tail) {
 if (hasReversedEdge(head, tail)) {
  return reversedEdges.get(head).get(tail);
 } else {
  return null;
 }
}

代码示例来源:origin: apache/tajo

public static Properties get(@Nullable Properties connParam) {
  Properties copy = connParam == null ? new Properties() : (Properties) connParam.clone();
  for (Map.Entry<String, String> entry : DEFAULT_PARAMS.entrySet()) {
   if (!copy.contains(entry.getKey())) {
    copy.setProperty(entry.getKey(), entry.getValue());
   }
  }
  return copy;
 }
}

代码示例来源:origin: apache/tajo

public static Set<Class> findClasses(@Nullable Class targetClass, String packageFilter, Predicate predicate) {
 Set<Class> classSet = new HashSet<>();
 String classpath = System.getProperty("java.class.path");
 String[] paths = classpath.split(System.getProperty("path.separator"));
 for (String path : paths) {
  File file = new File(path);
  if (file.exists()) {
   findClasses(classSet, file, file, true, targetClass, packageFilter, predicate);
  }
 }
 return classSet;
}

代码示例来源:origin: org.apache.tajo/tajo-common

public static Set<Class> findClasses(@Nullable Class targetClass, String packageFilter, Predicate predicate) {
 Set<Class> classSet = new HashSet<Class>();
 String classpath = System.getProperty("java.class.path");
 String[] paths = classpath.split(System.getProperty("path.separator"));
 for (String path : paths) {
  File file = new File(path);
  if (file.exists()) {
   findClasses(classSet, file, file, true, targetClass, packageFilter, predicate);
  }
 }
 return classSet;
}

代码示例来源:origin: org.apache.tajo/tajo-core

private Tablespace getTablespaceHandler(@Nullable String tableSpaceName, @Nullable URI tableUri) {
  if (tableSpaceName != null) {
   return TablespaceManager.getByName(tableSpaceName);
  } else if (tableUri != null) {
   return TablespaceManager.get(tableUri);
  } else {
   return TablespaceManager.getDefault();
  }
 }
}

代码示例来源:origin: apache/tajo

public Context getBlockPlanStrings(@Nullable LogicalPlan plan, LogicalNode node) throws TajoException {
 Stack<LogicalNode> stack = new Stack<>();
 Context explainContext = new Context();
 visit(explainContext, plan, null, node, stack);
 return explainContext;
}

代码示例来源:origin: org.apache.tajo/tajo-common

@Override
public @Nullable E getEdge(V tail, V head) {
 E edge = super.getEdge(tail, head);
 if (edge != null) {
  return edge;
 }
 edge = super.getEdge(head, tail);
 if (edge != null) {
  return edge;
 }
 return null;
}

代码示例来源:origin: apache/tajo

@Override
public EvalNode bind(@Nullable EvalContext evalContext, Schema schema) {
 if (evalContext != null) {
  timezone = evalContext.getTimeZone();
 }
 return super.bind(evalContext, schema);
}

代码示例来源:origin: apache/tajo

private static <T extends CatalogStore> String getCatalogURI(@NotNull Class<T> clazz,
                               @Nullable String schemeSpecificPart,
                               @NotNull String testDirPath)
  throws UnsupportedCatalogStore {
 String uriScheme = getCatalogURIScheme(clazz);
 StringBuilder sb = new StringBuilder("jdbc:").append(uriScheme).append(":");
 if (schemeSpecificPart != null) {
  sb.append(schemeSpecificPart).append(":");
 }
 sb.append(testDirPath).append("/db;create=true");
 return sb.toString();
}

代码示例来源:origin: apache/tajo

@Override
public List<String> getTableList(@Nullable final String databaseName) {
 final BlockingInterface stub = conn.getTMStub();
 StringListResponse response;
 try {
  response = stub.getTableList(null, conn.getSessionedString(databaseName));
 } catch (ServiceException e) {
  throw new RuntimeException(e);
 }
 ensureOk(response.getState());
 return response.getValuesList();
}

相关文章