本文整理了Java中org.apache.tajo.annotation.Nullable.<init>()
方法的一些代码示例,展示了Nullable.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Nullable.<init>()
方法的具体详情如下:
包路径:org.apache.tajo.annotation.Nullable
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!