本文整理了Java中org.apache.tajo.annotation.Nullable
类的一些代码示例,展示了Nullable
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Nullable
类的具体详情如下:
包路径:org.apache.tajo.annotation.Nullable
类名称:Nullable
暂无
代码示例来源: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: org.apache.tajo/tajo-client
/**
* 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-core
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: org.apache.tajo/tajo-core
/**
* Add a pair of (key, value).
* The key is not copied.
*
* @param key
* @param value
* @return
*/
public E putWihtoutKeyCopy(@Nullable KeyTuple key, E value) {
return super.put(key, value);
}
}
代码示例来源:origin: apache/tajo
/**
* Add a pair of (key, value).
* The key is not copied.
*
* @param key
* @param value
* @return
*/
public E putWihtoutKeyCopy(@Nullable KeyTuple key, E value) {
return super.put(key, value);
}
}
代码示例来源: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-plan
public PartitionPathFilter(Schema schema, @Nullable EvalNode partitionFilter) {
this.schema = schema;
this.partitionFilter = partitionFilter;
if (this.partitionFilter != null) {
this.partitionFilter.bind(null, schema);
}
}
代码示例来源:origin: org.apache.tajo/tajo-client
public static ClientDelegate newDefaultDelegate(ServiceDiscovery discovery,
@Nullable Properties clientParams)
throws ClientUnableToConnectException {
return new LegacyClientDelegate(discovery, clientParams);
}
}
内容来源于网络,如有侵权,请联系作者删除!