1回答
假设我有这样的东西
something.stream()
.filter(filterMethod) // Same
.map(mapMethod) //
.map(somethingElse)
.filter(filterMethod) // Same
.map(mapMethod) //
.filter(otherFilter)
.filter(filterMethod) // Same
.map(mapMethod)
浏览 1提问于2017-10-11得票数 3
2回答
我在玩scala流。这里是从给定数字开始的所有整数的流。
我添加了一个println来跟踪from函数的每个调用。
def from(n: Int): Stream[Int] = n #:: from({ println(n); n + 1 })
val nats = from(0) //> nats : Stream[Int] = Stream(0, ?)
nats.take(4).toList //> 0
//| 1
//| 2
浏览 1提问于2016-08-01得票数 2
回答已采纳
2回答
我的理解是，一旦执行了终端操作(如Stream或count() )，Java8Java就会被认为是被消耗的。
然而，下面的测试用例multipleFilters_separate抛出一个IllegalStateException，尽管filter是一个惰性的中间操作，只是作为两个语句调用。但是，我可以将这两个过滤器操作链接到一个语句中，这样就可以工作了。
@Test(expected=IllegalStateException.class)
public void multipleFilters_separate() {
Stream<Double> ints = Stre
浏览 1提问于2017-08-13得票数 18
回答已采纳
2回答
我为范围查询编写了一个Stream，它不能正常工作。你知道如何用lua设置许多过滤器吗？
查询：
SELECT id1, id2, link_type, visibility, data, time, version FROM linktable
WHERE id1 = <id1> AND
link_type = <link_type> AND
time >= <minTime> AND
time <= <maxTimestamp> AND
visibility = VISIBILITY_DEFAULT
ORDER B
浏览 7提问于2016-11-28得票数 1
回答已采纳
1回答
我有一个主主题和多个谓词，每个谓词都有一个与其关联的输出主题。我希望将每条记录发送到谓词解析为true的所有主题。我使用Luwak测试记录满足的谓词(要使用这个库，您可以使用一个带有谓词列表的文档，并告诉您匹配的文档-也就是说，我只调用它一次以获得满意的谓词列表)。
我试图在KStream上使用Kafka流，但似乎没有合适的方法(KStream#branch只将记录路由到单个主题)。
一种可能的办法是：
Stream from master
Map the values into a format with the original content and the list of matchi
浏览 3提问于2017-02-22得票数 10
回答已采纳
我使用KStream filter功能根据匹配的谓词写入特定主题：
val builder: KStreamBuilder = new KStreamBuilder()
val stream: KStream[String, String] = builder.stream(config)
val filter1 = stream.filter(predicate1)
val filter2 = stream.filter(predicate2)
filter1.to("out-topic-1")
filter2.to("out-topic-2")
new
浏览 2提问于2017-11-07得票数 0
回答已采纳
1回答
如果Observable在完成之前没有发出一个值，我希望“抛出”自定义错误。
让我试着展示一个例子：
Observable<SomeClass> stream = ...
stream
.filter(...)
.singleOrError(new MyCustomException())
所以我有一个SomeClass对象流。如果fitler()不只发出一个元素，我想发出自定义错误。
浏览 0提问于2017-01-02得票数 6
回答已采纳
我有一个循环来执行我想做的事情--它将A类型的对象添加到results列表中：
ArrayList<A> results = new ArrayList<>();
for (A a: listOfA) {
for (B b : a.getListOfB()) {
if ("myString".equals(b.getMyString())) {
results.add(a);
}
}
}
现在我想用Java 8流重构我的代码，我想出了这个解决方案，因为它收集B类型的对象而不是A - List<A> resu
浏览 3提问于2022-02-10得票数 3
回答已采纳
说：
流水线源代码的遍历直到流水线的终端操作执行后才开始。
那么为什么下面的代码会抛出：
java.lang.IllegalStateException:流已被操作或关闭
Stream<Integer> stream = Stream.of(1,2,3);
stream.filter( x-> x>1 );
stream.filter( x-> x>2 ).forEach(System.out::print);
根据API的第一过滤操作不应该在流上操作。
浏览 27提问于2016-01-08得票数 25
回答已采纳
我有一个包含多个嵌套对象的复杂对象列表。我需要比较复杂对象中的4个元素，以确定它是否重复并删除它。这是要比较重复项的复杂对象和元素 - Segment
* Billing (string) - element to compare for duplication
* Origin (object)
number (int) - element to compare for duplication
string1
string2
* Destination (object)
浏览 10提问于2020-06-25得票数 2
回答已采纳
4回答
我正在尝试创建一个函数，它接受多个谓词条件，并根据这些条件过滤流。我找不到任何东西，但我的retList似乎只是包含输入，而不是输入的过滤版本。
以下是我得到的指示：
//TODO生成一个Integer流，并将其设置为对于每个谓词p的输入，设置此流变量等于将filter(p)应用于流的结果。在完成for每个循环之后，将结果流收集到一个列表中，就像我们在前面的问题中所做的那样，返回结果列表。
这就是我目前的情况：
public static List<Integer> matchAll(Stream<Integer> input, Predicate<Inte
浏览 1提问于2019-11-13得票数 1
回答已采纳
3回答
我有一个对象，它看起来如下所示
class MyObject {
String type;
List<String> subTypes;
}
给出一个MyObject的列表，可以使用Java 8流对类型和子类型进行过滤吗？
到目前为止我已经
myObjects.stream()
.filter(t -> t.getType().equals(someotherType)
.collect(Collections.toList());
但在此范围内，我还希望在每个subTypes上都有另一个过滤器，以过滤特定子类型上的过滤器。我不知道该怎么做
浏览 7提问于2015-01-07得票数 14
回答已采纳
1回答
所以我在python中使用tweepy已经有一段时间了，我试图通过"like“和"retweet”或"RT“来过滤tweet。
问题是我不知道如何通过两个单词进行过滤。这是我现在成功过滤一个单词的代码，但我想同时过滤2个单词。
tweets_listener = MyStreamListener(api)
stream = tweepy.Stream(api.auth, tweets_listener)
stream.filter(track=["giveaway"], languages=["en"])
浏览 0提问于2019-12-07得票数 0
我正在努力返回只包含item.baz.fooz == 'snafu‘的物品。我已经匿名了下面的代码和来源。您的协助将不胜感激。我的数据来源：
{
"data": {
"searches": [
{
"apples": [
{
"pears": [
{
"sets": [
{
"ite
浏览 0提问于2019-06-04得票数 1
回答已采纳
//i have a list of student type
List<Student> list2 = new ArrayList<>();
list2.add(new Student(101, "piyush"));
list2.add(new Student(102, "Raman"));
list2.add(new Student(109, "Raman"));
//i converted this list to Map
Map<Inte
浏览 6提问于2017-08-06得票数 2
当使用Kafka流DSL时，是否有一种方法可以使用相同的主题作为两个不同处理例程的源？
StreamsBuilder streamsBuilder = new StreamsBuilder();
// use the topic as a stream
streamsBuilder.stream("topic")...
// use the same topic as a source for KTable
streamsBuilder.table("topic")...
return streamsBuilder.build();
上面的简单实现在运行时
浏览 0提问于2018-09-20得票数 5
回答已采纳
1回答
我有两个列表，一个包含ProductDto，另一个包含ConsumedProductDto @Builder
@Getter
@ToString
public class ProductDto {
private final String id;
private final String productName;
private final Double calories;
private final Double protein;
private final Double fat;
private final Double carbohydr
浏览 20提问于2019-08-25得票数 1
5回答
有人能告诉我Stream的中间操作和终端操作有什么区别吗？
Stream操作被组合成管道来处理流。所有操作都是中间操作或终端..means？
浏览 5提问于2017-12-07得票数 35
回答已采纳
我想要重写一个方法，该方法循环遍历一个映射的键，并返回值，如果该键选择了一个属性。更具体而言：
Map<JRadioButton, Configuration> radioButtons = ...
public Configuration getSelectedConfiguration()
for (JRadioButton radioButton : radioButtons.keySet()) {
if(radioButton.isSelected()){
return radioButtons.get(rad
浏览 3提问于2017-05-18得票数 2
回答已采纳
我试图使用.stream操作符在List<>中查找对象，但得到一个语法错误我无法解决，尽管按照我在net...hopefully上找到的示例，有人可以帮助解决我不理解的任何内容。
我将以下设置为要存储在List<>中的对象：
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Getter
@Setter
@NoArgsConstructor
public class JelCodeMapping {
private String jelCodeId;
浏览 5提问于2021-03-18得票数 0
回答已采纳
3回答
给定以下函数：
public static <X> List<X> filterWithVarargPredicates(
List<X> allProducts,
Predicate<X>... predicates
) {
for (Predicate<X> predicate : predicates) {
allProducts = allProducts.stream()
.filter(predicate)
浏览 1提问于2015-10-02得票数 4
请注意，SRS支持为特定的解决方案生成单个m3u8文件。SRS还支持为多分辨率和比特率场景生成额外的主m3u8文件吗？
所需的主m3u8示例：
#EXTM3U
#EXT-X-VERSION:3
#EXT-X-STREAM-INF:BANDWIDTH=2340800,RESOLUTION=960x540,CODECS=“avc1.4d401f,mp4a.40.2”
index_0.m3u8
#EXT-X-STREAM-INF:BANDWIDTH=1170400,RESOLUTION=480x270,CODECS=“avc1.4d4015,mp4a.40.2"
index_1.m3u8
#
浏览 24提问于2022-04-18得票数 4
回答已采纳
我正在写一个路由器，它流从twitter API的推文，并不断给我发送推文，我想在浏览器上显示这些推文(即，我需要不断地向浏览器发送响应)。假设在每条tweet之后发送响应。我面临的问题是，我只能为每个请求发送一次响应。我正在附上代码。我可以对单个请求发送多个响应吗？
router.get('/:AddKey', function(req,res,next){
const id = req.params.AddKey
var stream = T.stream('statuses/filter', { track: id })
console.log
浏览 5提问于2018-02-17得票数 0
T1:
apis :
- api: r1
cnfig :
- country: M1
userseg: 5
row: 4
- country: M2
userseg: 11
row: 10
- api: r2
cnfig :
- country: M1
userseg: 5
row: 6
- country: M2
浏览 13提问于2020-01-10得票数 1
回答已采纳
我有一张地图：
Map<String, Map<String, Integer>> rootMap
如果rootMap键包含使用流的stringValue，那么我希望返回rootMap值stringValue。
我试过：
rootMap.entrySet().stream().filter(e -> e.getKey().contains(stringValue)).collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
但我得到的是Map<Object, Object>而不
浏览 1提问于2021-01-11得票数 0
回答已采纳
2回答
如何在Java中映射多个变量？
、、、、
我有一个在包含枚举i的列表中过滤的方法。
if (availableImageSizes.stream()
.filter(t -> t.getNameSuffix().equals("-xs"))
.findFirst().isPresent())
{
int width = availableImageSizes.stream()
.filter(t -> t.getNameSuffix().equals("-
浏览 4提问于2020-11-27得票数 3
回答已采纳
2回答
流中谓词的通配符泛型类型不适用
、、、、
我有一个精简的代码版本来说明这个问题。
下面是我得到的编译错误：
The method anyMatch(Predicate<? super capture#26-of ?>) in the type Stream<capture#26-of ?> is not applicable for the arguments (Predicate<Map<?,?>>)
我的代码：
private void func(Object o) {
Predicate<Map<?, ?>> pred = m -> true;
浏览 9提问于2022-11-02得票数 0
回答已采纳
5回答
根据一些运动成绩数据，我有一个Fixture对象，它包含getHome()和getAway()方法。我想缩短我编写的这个方法，只使用一个lambda函数(而不是创建一个新列表和两个lambda)，这可能吗？
private Collection<FixtureResult> finalResults(Team team) {
List<FixtureResult>finalResults = new ArrayList<>();
List<FixtureResult> homeResults = resultList.
浏览 1提问于2018-03-19得票数 17
回答已采纳
2回答
需要帮助理解一些SICP流示例
、、、、
我试图了解这个函数是如何工作的。
(define (sieve stream)
(cons-stream
(stream-car stream)
(sieve (stream-filter
(lambda (x)
(not (divisible? x (stream-car stream))))
(stream-cdr stream)))))
(define primes (sieve (integers-starting-from 2)))
简单地说，我使用一个从2开始生成所有整数的流，根据这本书，
浏览 19提问于2022-09-12得票数 1
回答已采纳
1回答
在转换一些代码时，我需要一些帮助，我必须使用非常优秀的Java8Stream库。本质上，我有一堆学生对象，我想返回一个过滤对象的列表，如下所示：
List<Integer> classRoomList;
Set<ScienceStudent> filteredStudents = new HashSet<>();
//Return only 5 students in the end
int limit = 5;
for (MathStudent s : mathStudents)
{
// Get the scienceStudent with
浏览 2提问于2015-11-20得票数 2
回答已采纳
3回答
例如，我需要这样的东西：
Collection<String> collection = /* ... */;
Stream<Object> stream = /* ... */;
boolean containsAll = stream.map(Object::toString).containsAll(collection);
当然，我可以使用Collection方法和调用Collection.containsAll()将流的所有元素累加到另一个Collection.containsAll()中，但是如果流太大，并且处理所有元素效率低下，该怎么办？
浏览 1提问于2019-10-07得票数 12
回答已采纳
1回答
短消息接收器不工作
、、、、
我是新的安卓短信，我正在努力研究它。所以我试着制作一个总是在后台工作的android应用程序，当我收到短信内容为"hello“(有人通过短信向我的手机发送”hello“)时，音乐就会播放。
我搜索了所有的网络，我建立了一个在AVD上工作的项目，但是当我在我的手机上测试它时，它没有工作：
import info.kfsoft.android.R.raw;
import android.app.Notification;
import android.app.NotificationManager;
import android.content.BroadcastReceiver;
imp
浏览 0提问于2014-09-17得票数 0
回答已采纳
1回答
我有一个关于以下代码的问题： import java.io.*
import java.nio.*
import org.springframework.core.io.FileSystemResource;
import org.springframework.core.io.Resource;
public static void FileReader {
String filePath = "C:\Downloads\"";
Stream<Path> walk = Files.walk(Paths.get(filePath));
浏览 19提问于2020-09-01得票数 1
回答已采纳
1回答
我从API中得到以下响应：
[
{
"country":"INDIA",
"region": "Asia",
"doorNo": "12",
"pinCode": "345"
},
{
"country":"Angolia",
"region": "Asia",
"doorNo": "13",
"pinCode": &
浏览 7提问于2022-08-11得票数 -1
5回答
我知道，每当我们在一个terminal method上调用任何stream时，它都会关闭。
如果我们试图调用封闭流上的任何其他终端函数，就会产生一个java.lang.IllegalStateException: stream has already been operated upon or closed。
但是，如果我们想要多次重用相同的流()，该怎么办？
如何做到这一点？
浏览 2提问于2017-03-02得票数 9
回答已采纳
我只需要一个映射，它包含不匹配某个regexp的所有键和值。在Java中是否有一种简单的方法来否定find()或matches()？
Pattern pattern = Pattern.compile("(.*)"+dateFormatter.format(Date.from(now))+"(.*)");
Map<String, Writer> toBeClosed = orcWriterMap.entrySet().stream()
.filter(entry -> pattern.matcher(entry.getKey()).fin
浏览 9提问于2017-03-17得票数 1
回答已采纳
1回答
我试图实现一个覆盖与ffmpeg，其中接受两个flv文件作为输入，并作出一个输出和两个视频同时播放。在ffmpeg命令下，一切都很顺利：
ffmpeg -i input1.flv -vf "[in] scale=359:320, pad=2*iw+6:ih [left]; movie=input2.flv, scale=359:320 [right]; [left][right] overlay=365:0 [out]" -b:v 3600k -y output.flv
但是问题是第二个视频的声音，这是从output.flv中缺失的，只有input1声音在output.flv中
浏览 11提问于2013-01-08得票数 0
我不喜欢forEach的部分，但是我不知道如何用lambda更好地完成这个任务。
list1.stream().map(element -> {
list2.forEach(item -> {
if (element.getKey().equals(item.getKeyNextYear())) {
element.setSummPreviosYear(item.getSumm());
element.setCashboxCountPreviosYear(item.getCashboxCount());
浏览 1提问于2017-11-24得票数 2
回答已采纳
2回答
让我们考虑以下布尔条件：
A,B,C,D。
现在我们要根据它们筛选列表：
list.stream().filter(x -> A).filter(x -> B).filter(x -> C).filter(x -> D)
list.stream().filter(x -> A && B && C && D)
哪种方式更好？我是说效率和优雅。
浏览 4提问于2017-11-03得票数 4
回答已采纳
2回答
我试图使用多个过滤器来查询国际航空公司，并参考了这个。
我能够根据给定的lua脚本查询aerospike的一个过滤器参数，但当必须传递超过2个筛选参数(例如，传递两个以上的参数，例如年龄、性别和密码)时，我可以使用lua脚本。
这是我第一次和lua在一起。
Lua脚本：
local function map_profile(record)
return map {name=record.name, password=record.password}
end
function check_password(stream,password)
local function filter_pass
浏览 8提问于2015-12-09得票数 3
回答已采纳
我正在学习使用流，并尝试在没有Scanner.hasNext()的文件中获取包含元音且单词长度大于4的所有单词。
对于该文件的示例，我想编写如下代码
Stream<String> text = Files.lines(Paths.get(example.txt));
List<String> result = text.filter(w->w.length()>4)
.filter(w -> w.contains("a")||w.contains("e")||
w.contains("i")||
浏览 2提问于2020-12-15得票数 1
我试图用lambda表达式/流在Java8中迁移一个愚蠢的白痴4调用，但我正在挣扎。
以下是我所做的(为了更好地理解而替换名字)
companySiteList.stream()
.filter(companySite -> companySite.getId().equals("ID"))
.map(obj -> obj.getEmployeeList().stream()
.filter(employee -> employee.getId().equals("ID_EMPLOYEE"))
. ... ???
)
pri
浏览 1提问于2018-02-13得票数 1
回答已采纳
4回答
return userRepo
.findAll()
.stream()
.filter(user -> user.getIsActive()==active)
.filter(user -> user.getEyeColor().equalsIgnoreCase(eyeColor))
.filter(user -> user.getBalance() >= balance.doubleValue())
.filter(
浏览 4提问于2020-02-04得票数 2
回答已采纳
我想将Stream<String>转换为String并打印所有字符串。
Stream<String> result= Stream.of("do","re","ma","po","fa","si")
.filter(str -> str.length()>5)
.peek(System.out:: println);
浏览 7提问于2022-02-09得票数 -1
在使用以下代码时，我会遇到偶尔出现的数组索引超出界限的异常。有什么线索吗？数组的大小总是在29-30左右。
logger.info("devicetripmessageinfo size :{}",deviceMessageInfoList.size());
deviceMessageInfoList.parallelStream().forEach(msg->{
if(msg!=null && msg.getMessageVO()!=null)
{
DeviceTripMessageInfo curren
浏览 14提问于2020-10-14得票数 5
24回答
我试图使用Java 8来查找LinkedList中的元素。但是，我要保证，筛选标准只有一个匹配项。
取此代码：
public static void main(String[] args) {
LinkedList<User> users = new LinkedList<>();
users.add(new User(1, "User1"));
users.add(new User(2, "User2"));
users.add(new User(3, "User3"));
U
浏览 11提问于2014-03-27得票数 311
回答已采纳
3回答
如何使用java8流筛选列表并返回查找元素，如果它是筛选列表中的唯一元素，否则(如果有更多符合条件的元素，或者没有满足条件的结果)返回(例如，Optional.empty() )。
我需要这样的东西：
假设我有一个：
List<String> list = Arrays.asList("Apple","Banana","Peach");
那我想：
Optional<String> string = list.stream()
.filter(item -> item.startsWith("A"
浏览 2提问于2018-03-13得票数 8
回答已采纳
1回答
我正在尝试使用c++中的ffmpeg将视频文件分成视频部分(h264, mpeg4, h265, vp8, etc)和音频部分(mp3, aac, ac3, etc)以及字幕部分(srt)。
音频部分出来的很好，可以在我所有的媒体播放器上播放，字幕部分也是如此。然而，视频部分出来没有错误，并保存为.h264文件，但当我使用ffprobe检查它或播放它时，它总是给出错误"Invalid data found when processing input"。
下面的代码
/* Separate a media file into audio, video and subtitle f
浏览 0提问于2016-02-20得票数 0
我试图将一个非常大的JSON文件加载到R中，因为该文件太大，无法装入机器上的内存，我发现使用jsonlite包的stream_in/stream_out函数非常有用。使用这些函数，我可以先将数据子集为块而不需要加载，将子集数据写入一个新的、较小的JSON文件中，然后以data.frame的形式加载该文件。但是，在使用stream_out编写时，这个中间JSON文件正在被截断(如果这是正确的话)。我现在想进一步详细解释一下。
我正在尝试的东西：
我编写了如下代码(以下是文档中的一个示例)：
con_out <- file(tmp <- tempfile(), open = "
浏览 3提问于2017-09-05得票数 0
这是将列表与另一个列表连接的代码。还使用静态实用程序来使用id和name的hashmap。
我添加了空检查来使用NPE保护代码。
其主要目的是使其具有可读性。有人能帮我检查一下代码吗？
public List<PGRatingResponse> collatePGRatingsbyVendor(List<PGRatingConfig> pgRatingSansPgname,
List<Vendor> vendors) {
return pgRatingSansPgname.stream().filt
浏览 0提问于2021-06-22得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
