本文整理了Java中scala.collection.Seq.iterator()
方法的一些代码示例,展示了Seq.iterator()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Seq.iterator()
方法的具体详情如下:
包路径:scala.collection.Seq
类名称:Seq
方法名:iterator
暂无
代码示例来源:origin: edu.cmu.ml.rtw/matt-util
public static <V> List<V> scalaToJavaList(scala.collection.Seq<V> scalaList) {
List<V> javaList = Lists.newArrayList();
scala.collection.Iterator<V> iterator = scalaList.iterator();
while (iterator.hasNext()) {
javaList.add(iterator.next());
}
return javaList;
}
}
代码示例来源:origin: com.cerner.common.kafka/common-kafka-admin
/**
* Returns the set of all topics in the Kafka cluster
*
* @return unmodifiable set of all topics in the Kafka cluster
*
* @throws AdminOperationException
* if there is an issue retrieving the set of all topics
*/
public Set<String> getTopics() {
LOG.debug("Retrieving all topics");
try {
return Collections.unmodifiableSet(convertToJavaSet(zkUtils.getAllTopics().iterator()));
} catch (ZkException e) {
throw new AdminOperationException("Unable to retrieve all topics", e);
}
}
代码示例来源:origin: com.cerner.common.kafka/common-kafka-admin
/**
* Returns the replication factor for the given topic
*
* @param topic
* a Kafka topic
* @return the replication factor for the given topic
*
* @throws IllegalArgumentException
* if topic is null, empty or blank
* @throws AdminOperationException
* if there is an issue retrieving the replication factor
*/
public int getTopicReplicationFactor(String topic) {
if (StringUtils.isBlank(topic))
throw new IllegalArgumentException("topic cannot be null, empty or blank");
try {
return convertToJavaSet(zkUtils.getReplicasForPartition(topic, 0).iterator()).size();
} catch (ZkException | KafkaException e) {
throw new AdminOperationException("Unable to read replication factor for topic: " + topic, e);
}
}
代码示例来源:origin: org.openkoreantext/open-korean-text
/**
* Tokenize with the builder options into a String Iterable.
*
* @param tokens Korean tokens (output of tokenize(CharSequence text)).
* @return List of token strings.
*/
public static List<String> tokensToJavaStringList(Seq<KoreanToken> tokens, boolean keepSpace) {
Iterator<KoreanToken> tokenized = tokens.iterator();
List<String> output = new LinkedList<>();
while (tokenized.hasNext()) {
final KoreanToken token = tokenized.next();
if (keepSpace || token.pos() != KoreanPos.Space()) {
output.add(token.text());
}
}
return output;
}
代码示例来源:origin: com.cerner.common.kafka/common-kafka-admin
Set<Object> partitionList = convertToJavaSet(partitions.iterator());
if (partitionList.isEmpty()) {
throw new AdminOperationException("Partition count is 0 for topic: " + topic);
代码示例来源:origin: dcaoyuan/nbscala
@Override
public void run(ResultIterator resultIterator) throws Exception {
ScalaRootScope rootScope = ((ScalaParserResult) resultIterator.getParserResult()).rootScope();
if (rootScope == null) {
return;
}
rootScope.visibleDfns(ElementKind.CLASS);
scala.collection.Seq<AstDfn> tmpls = rootScope.visibleDfns(ElementKind.CLASS);
if (!tmpls.isEmpty()) {
scala.collection.Iterator itr = tmpls.iterator();
while (itr.hasNext()) {
AstDfn tmpl = (AstDfn) itr.next();
if (classes[0].length() > 0) {
classes[0] = classes[0] + " "; // NOI18N
}
classes[0] = classes[0] + tmpl.getName().toString().replace('.', '/') + "*.class"; // NOI18N
}
}
}
});
代码示例来源:origin: openzipkin/zipkin-finagle
@Override public void incrementMessagesDropped(Throwable cause) {
if (cause instanceof FinagleSender.WrappedException) cause = cause.getCause();
Seq<Traversable<String>> paths = Throwables.mkString(cause).inits().toSeq();
for (Iterator<Traversable<String>> i = paths.iterator(); i.hasNext();) {
messagesDropped.counter(i.next().toSeq()).incr();
}
}
代码示例来源:origin: io.zipkin.finagle2/zipkin-finagle
@Override public void incrementMessagesDropped(Throwable cause) {
if (cause instanceof FinagleSender.WrappedException) cause = cause.getCause();
Seq<Traversable<String>> paths = Throwables.mkString(cause).inits().toSeq();
for (Iterator<Traversable<String>> i = paths.iterator(); i.hasNext();) {
messagesDropped.counter(i.next().toSeq()).incr();
}
}
代码示例来源:origin: open-korean-text/elasticsearch-analysis-openkoreantext
@Override
protected Seq<KoreanToken> perform(Seq<KoreanToken> tokens) {
KoreanToken[] performed = new KoreanToken[tokens.length()];
int i = 0;
Iterator<KoreanToken> tokenIterator = tokens.iterator();
while (tokenIterator.hasNext()) {
KoreanToken token = tokenIterator.next();
performed[i++] = token.stem().nonEmpty() ? stem(token) : token;
}
return JavaConverters.asScalaBuffer(Arrays.asList(performed)).toSeq();
}
代码示例来源:origin: io.zipkin.finagle/zipkin-finagle
@Override public void incrementMessagesDropped(Throwable cause) {
Seq<Traversable<String>> paths = Throwables.mkString(cause).inits().toSeq();
for (Iterator<Traversable<String>> i = paths.iterator(); i.hasNext();) {
messagesDropped.counter(i.next().toSeq()).incr();
}
}
代码示例来源:origin: org.openkoreantext/open-korean-text
/**
* Transforms the tokenization output to List<KoreanTokenJava>
*
* @param tokens Korean tokens (output of tokenize(CharSequence text)).
* @return List of KoreanTokenJava.
*/
public static List<KoreanTokenJava> tokensToJavaKoreanTokenList(Seq<KoreanToken> tokens, boolean keepSpace) {
Iterator<KoreanToken> tokenized = tokens.iterator();
List<KoreanTokenJava> output = new LinkedList<>();
while (tokenized.hasNext()) {
KoreanToken token = tokenized.next();
String stem = "";
if (token.stem().nonEmpty()) {
stem += token.stem().get();
}
if (keepSpace || token.pos() != KoreanPos.Space()) {
output.add(new KoreanTokenJava(
token.text(),
KoreanPosJava.valueOf(token.pos().toString()),
token.offset(),
token.length(),
token.unknown(),
stem
));
}
}
return output;
}
代码示例来源:origin: open-korean-text/elasticsearch-analysis-openkoreantext
private Seq<KoreanToken> convertPhrasesToTokens(Seq<KoreanPhrase> phrases) {
KoreanToken[] tokens = new KoreanToken[phrases.length()];
Iterator<KoreanPhrase> iterator = phrases.iterator();
int i = 0;
while (iterator.hasNext()) {
KoreanPhrase phrase = iterator.next();
tokens[i++] = new KoreanToken(phrase.text(), phrase.pos(), phrase.offset(), phrase.length(), scala.Option.apply(null), false);
}
Arrays.sort(tokens, (o1, o2) -> {
if(o1.offset()== o2.offset())
return 0;
return o1.offset()< o2.offset()? -1 : 1;
});
return JavaConverters.asScalaBuffer(Arrays.asList(tokens)).toSeq();
}
}
代码示例来源:origin: dcaoyuan/nbscala
scala.collection.Iterator<AstDfn> itr = rootScope.visibleDfns(ElementKind.PACKAGE).iterator();
while (itr.hasNext()) {
AstDfn packaging = itr.next();
itr = objs.iterator();
while (itr.hasNext()) {
AstDfn obj = itr.next();
代码示例来源:origin: uber/hudi
@Override
public void onTaskEnd(SparkListenerTaskEnd taskEnd) {
Iterator<AccumulatorV2<?, ?>> iterator = taskEnd.taskMetrics().accumulators().iterator();
while (iterator.hasNext()) {
AccumulatorV2 accumulator = iterator.next();
if (taskEnd.stageId() == 1 && accumulator.isRegistered() && accumulator.name().isDefined()
&& accumulator.name().get().equals("internal.metrics.shuffle.read.recordsRead")) {
stageOneShuffleReadTaskRecordsCountMap.put(taskEnd.taskInfo().taskId(), (Long) accumulator.value());
}
}
}
});
内容来源于网络,如有侵权,请联系作者删除!