org.apache.tajo.annotation.Nullable类的使用及代码示例

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

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

相关文章