我使用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
回答已采纳
4回答
Java 8流或条件
、、、
请看这段代码：(这是工作代码，但我不喜欢使用2行代码，所以我想知道如何让它变得更好)
ItemDetails[] items = response.getDetailsList();
items = Arrays.stream(items).filter(x -> !x.getName().equalsIgnoreCase("acl1")).toArray(ItemDetails[]::new);
items = Arrays.stream(items).filter(x -> !x.getName().equalsIgnoreCase("acl2"
浏览 3提问于2016-11-11得票数 9
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
1回答
我从API中得到以下响应：
[
{
"country":"INDIA",
"region": "Asia",
"doorNo": "12",
"pinCode": "345"
},
{
"country":"Angolia",
"region": "Asia",
"doorNo": "13",
"pinCode": &
浏览 7提问于2022-08-11得票数 -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回答
我有一个关于以下代码的问题： 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
回答已采纳
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
回答已采纳
我只需要一个映射，它包含不匹配某个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
回答已采纳
2回答
注意:这个问题是，而不是与java.util.Optional相关的。
在处理流时，我经常使用这样的逻辑：
Stream<FooBar> stream = myInitialStream();
if (needsFilter1) stream = stream.filter(c -> whatever1());
if (needsFilter2) stream = stream.filter(c -> whatever2());
...
return stream.collect(toList());
我试图实现的是使用链接将上面的代码转换为单个表达式。我觉得
浏览 1提问于2019-01-08得票数 6
回答已采纳
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
回答已采纳
4回答
我正在尝试创建一个函数，它接受多个谓词条件，并根据这些条件过滤流。我找不到任何东西，但我的retList似乎只是包含输入，而不是输入的过滤版本。
以下是我得到的指示：
//TODO生成一个Integer流，并将其设置为对于每个谓词p的输入，设置此流变量等于将filter(p)应用于流的结果。在完成for每个循环之后，将结果流收集到一个列表中，就像我们在前面的问题中所做的那样，返回结果列表。
这就是我目前的情况：
public static List<Integer> matchAll(Stream<Integer> input, Predicate<Inte
浏览 1提问于2019-11-13得票数 1
回答已采纳
1回答
我使用boost日志，并希望定义一个组合过滤器。我使用boost::log::init_from_stream从流中读取配置。在单一条件下进行过滤很好。我能做到
Filter = "%Channel% = A"
只从A频道获取日志条目，我可以做到
Filter = "%Severity% >= warn"
只获取具有警告或更高严重性的日志条目。
来了一个问题：，我想做一些事情，比如
Filter = " (%Channel% = A AND %Severity% >= warn)
OR (%Channel% = B A
浏览 2提问于2015-04-03得票数 2
回答已采纳
2回答
如果我想在多维对象数组中找到值的第一个实例，那么尝试了解如何使用一些java 8特性，并且正在处理多维对象数组。
Objects[][] someArray= .....
Arrays.stream(someArray)
.map(someArrayFirst -> Arrays.stream(someArrayFirst))
.map(unsure what to do here)
.filter(a -> a.equals("some value"))
浏览 2提问于2017-05-04得票数 1
回答已采纳
这是我的问题，我有一个列表lista1，我应该做的是：
map<key，List> m= groupby(lista1)；
M= lista.stream.collect(Collectors.groupingBy)；
对于每个组，返回一个具有某种条件的元素，并创建一个新的列表列表lista2 = MakeListfromGroup(m)
列表lista2；for (Map.Entry<key，List>条目: m.entrySet()) {A theOne；for (A : entry.getValue()) {if(条件){ theOne = a；}
浏览 2提问于2016-10-11得票数 0
回答已采纳
2回答
我理解为什么下面的代码是可以的。因为在调用终端操作之前正在修改集合。
List<String> wordList = ...;
Stream<String> words = wordList.stream();
wordList.add("END"); // Ok
long n = words.distinct().count();
但是为什么这段代码不正常呢？
Stream<String> words = wordList.stream();
words.forEach(s -> if (s.length() < 12) wor
浏览 1提问于2014-07-19得票数 5
回答已采纳
3回答
总而言之，下面的代码旨在过滤第一个参数中包含的实体。如果在第二个参数中指定了'change‘，它应该过滤更窄的结果。
当我运行这段代码时，我得到了一个错误：“IllegalStateException: stream已被操作或关闭。”
有没有一种方法可以重用相同的流？
我见过有人实现像Supplier>这样的东西，但我不认为它适用于这种情况。或者，我只是对它不够熟悉，无法理解如何使用供应商。
/**
* Filters through DocumentAuditEntityListing to find existence of the entities
*
浏览 2提问于2017-11-29得票数 2
2回答
我有一个boolean类型的方法，它返回谓词类型事件的数据流，我只想过滤掉最新的事件。
public boolean hascompletededucation(LocalDate asOnDate) {
Predicate<Courses> predicate = e -> ((e.hasincident1(asOnDate));
return f != null && f.stream().anyMatch(predicate);
我试着用
return f != null && f.str
浏览 0提问于2020-05-25得票数 6
我刚开始学习Scala，在处理流的时候，我把过滤器和takeWhile搞混了。
我偶然发现了这个生成质数的程序，它在流上同时使用takeWhile和filter。
lazy val ps: Stream[Int] = 2 #:: Stream.from(3).filter(i =>
ps.takeWhile{j => j * j <= i}.forall{ k => i % k > 0});
在实验中我发现
Stream.from(1).takeWhile(_ < 10).toList
返回我
List[Int] = List(1
浏览 0提问于2016-02-03得票数 10
回答已采纳
我有以下映射的超类：
@FilterDef(
name = "byCompanyUuid",
parameters = @ParamDef(
name = "companyUuid",
type = "string"
)
)
@Filter(
name = "byCompanyUuid",
condition = "COMPANY.UUID = :companyUuid&#
浏览 0提问于2020-12-18得票数 0
2回答
我有一个List<User> users。我想根据两个条件对清单进行筛选。
匹配UserID
匹配FilterName
公共类用户实现实体{
公共用户()私有字符串userName；私有字符串userId；私有列表筛选器；公共字符串getUserName() {返回userName；}公共字符串setUserName(字符串userName) { this.userName = userName；}公共字符串getUserId() {返回userId；}公共字符串setUserId(String userId) { this.userId = userId；}公共列表get
浏览 1提问于2017-11-07得票数 4
回答已采纳
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
回答已采纳
请帮助我，希望具体的ffmpeg参数包括在我的视频编码。
我的工作只是与视频流有关，所以这是我唯一要改变的。我收到一个已经为特定广播机构预编译的.mov文件，其中一些自包含的视频有4个流(1个视频、2个音频和一些其他时间编码流)。其他的则有多达17个流:1-视频，15-音频流，最后一种是不支持的tmcd。
我的流程管道只包括重新编码/再处理视频流，以及我需要传递到输出文件的其他所有内容-所有其他流，没有任何更改或更改。
在编码的这一步骤中，我从sec 2-3、4-5和6-8将icon.png插入到位置5:21中.为此，我使用map选项，因此我的编码字符串如下所示：
ffmpeg -i in.m
浏览 4提问于2020-09-23得票数 0
回答已采纳
我想知道java的流API是以相同的方式还是不同的方式处理这两种情况？如果它要为每个过滤器执行一个独立的循环，那么就性能而言，我认为有一个显著的差异。你觉得怎么样？
以下是两个条件
1. filter(cond1 && cond2 && cond3)
2. filter(cond1).filter(cond2).filter(cond3)
示例
List<Employee> emps1 = employees.stream()
浏览 0提问于2021-02-19得票数 2
回答已采纳
1回答
我正在使用Java 8，并尝试使用stream()。我想要实现的是，我有一个列表[1,2,3,4]，我想将偶数2和4加倍，然后用更新的值返回列表。因此，我将得到[1,4,3,8]作为结果。我尝试了以下操作，但它只返回了[4,8]。
List<Integer> myList =
Arrays.asList(1,2,3,4);
myList = myList
.stream()
.filter(n -> n%2==0)
.map(n -> n*2)
.collect(Collectors.toList());
浏览 2提问于2015-09-25得票数 1
回答已采纳
1回答
我有一个很小的列表，我必须根据元素的值将它分成两个列表。我想找两种方法来做-
或者使用筛选器迭代列表两次。
List<String> sublist1 = list.stream().filter(condition1).collect(ImmutableList.toImmutableList());
List<String> sublist2 = list.stream().filter(condition2).collect(ImmutableList.toImmutableList());
在流中使用forEach来赋值
List<String> s
浏览 1提问于2021-01-11得票数 0
2回答
我不能解释为什么我的过滤器不能工作。我在if-statement中排除该条件，以检查该条件是否真的为真。当DefaultLang (v.getLinkDefaultLang())和currentLang (v.getLinkCurrentLang())为空时，我不希望在我的List中包含该值！ manualResponseTOs.values().stream()
.filter(v -> isEmpty(v.getLinkDefaultLang()) && isEmpty(v.getLinkCurrentLang()
浏览 38提问于2020-10-02得票数 0
2回答
条件回调作用域
、、
我的模型中有一些条件回调
before_create :save_tempfile, :if => :has_stream_content?
after_create :add_track, :if => :has_stream_content?
before_update :add_track, :if => :has_stream_content?
有没有一种rails方法来组织条件回调作用域？像这样的Smth：
before_create :save_tempfile; after_create, before_update :add_track, :if =>
浏览 2提问于2014-01-24得票数 0
我是函数式编程的新手。我想知道我在这里错过了什么概念。
Stream<Employee> stream1 = getEmployeeListOne().stream();
Stream<Employee> stream2 = getEmployeeListTwo().stream();
Predicate<Employee>predicate=x->x.getFirstName().startsWith("L");
//Below line is compile time error
List&l
浏览 4提问于2021-06-19得票数 1
回答已采纳
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
我正在尝试使用lambda表达式来避免这样做： for (OrderEntity o: onEntryL) {
for(GeoFenceEventEntity g: o.getGeoFenceEvent()){
if(null != g.getEndAt() && g.getDynamoGeofenceType().equalsIgnoreCase("WAREHOUSE")){
//all of them, get data
}
}
} 在Lambda上尝试这样的东西(有错误)： List
浏览 15提问于2019-03-22得票数 1
回答已采纳
2回答
我有3个过滤器，但它们并不总是充满价值！
例如：
a=1，b=2，c=null
我有这个来过滤：
myList.stream()
.filter(item->item.a == a)
.filter(item->item.b == b)
.filter(item->item.c == c)
.Collect(collection.asList);
但这对我不起作用。我需要忽略c参数及其过滤器，如果c的输入是null，如下所示：
myList.stream()
.filter(item->item.a =
浏览 3提问于2019-11-25得票数 1
回答已采纳
2回答
我需要根据条件返回匹配的对象。我有这个3级列表，我需要在第二个列表中返回一个对象。
代码示例如下。
firstLevelList.getMySecondList().stream()
.flatMap(secondLevelList -> secondLevelList.getThirdLevelList().stream())
.filter(thirdLevelList -> thirdLevelList.getMyConditionObject() == "test")
现在我迷路了，我需要返回第二级
浏览 23提问于2018-01-11得票数 3
回答已采纳
1回答
我正在为两个列表的主地址相等的每个列表项设置id。
服务器POJO
public class Server {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name="id")
public Integer id;
@OneToMany (mappedBy = "server",cascade = CascadeType.ALL, orphanRemoval = true)
private List<IPAddress&g
浏览 3提问于2018-08-20得票数 1
我正在为我正在做的一个项目建立一些实体。我的问题是，我的hibernate过滤器上有一个无效的标识符错误。以下是一个简化的示例：
@Data
@Entity
@Table(name = "###")
public class C1 {
@OneToMany(mappedBy = "###")
@Filter(name = "C2.set1Filter")
private Set<C2> set1;
@OneToMany(mappedBy = "###")
@Filter(nam
浏览 0提问于2020-10-29得票数 1
回答已采纳
我有以下功能，试图逐步缩小输入集合，直到找到单个元素，即当发现单个项目时，筛选应该停止，因为应用附加筛选器可能会导致根本不匹配。
public List<MyObject> determinePotentialCandidates(List<MyObject> allCandidates) {
List<MyObject> candidates = allCandidates.stream()
.filter(this::firstCondit
浏览 5提问于2022-06-30得票数 -1
回答已采纳
1回答
在java 1.8或更高版本上，是否可以减少list的列表？ 当数字之和不能超过8时，我需要数字数组。 例如:我有一个列表:2，4，6。返回值可以是[ 2，4，6 ]或[2，6，4]。 我尝试了以下方法： List<Integer> nums = Arrays.asList(2,4,6);
nums.stream()
.filter((p) -> p <= 8)
.map(Collections::singleton)
.reduce(new ArrayList<List&l
浏览 24提问于2020-08-13得票数 1
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
回答已采纳
2回答
我需要从嵌套的List中找到一些对象。
我认为不需要类代码，因为过滤是在嵌套的For-Each Loop中公开的。
int value = someValue;
MyObject found = null;
for (List<MyObject> list : nestedList) {
for (MyObject myObject : list) {
if (myObject.isType() && myObject.getValue() == value) {
found = myObject;
}
}
}
另一个嵌套的
浏览 0提问于2019-06-13得票数 2
回答已采纳
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
回答已采纳
2回答
我们正在做一些链式过滤器来计算一组表达式，以只得到匹配所有表达式的项。看起来是这样的：
getItems().stream()
.filter(Item::isActive)
.filter(item -> fulfillsConditionA(item))
.filter(item -> item.getSomeNumber() < anyOtherNumber)
.forEach(item -> doSomeStuff(item));
虽然这与预期一样工作，但无法查看/记录特定筛选谓词筛
浏览 5提问于2022-02-23得票数 -2
使用Azure Stream Analytics将来自Blob或事件中心的事件流式传输到DocumentDB。已按照微软文档"“进行配置。
当我试图在流分析中将输入作为Event Hub或Blob，而将输出接收器作为documentdb时，那么我在文档资源管理器中看不到任何json数据。
在Stream Analytics查询中，我上传了一个JSON文件，并在一行中获得了输出。我关注了和的一些链接
但不能找出哪里出了问题。
浏览 3提问于2017-05-08得票数 0
附加代码段
List<Map<String,A>> listm=new ArrayList<>();
Map<String,A> map=new HashMap<>();
A a1=new A();
a1.setAge("30");
a1.setName("Mani");
map.put("1", a1);
A a2 =new A();
a2.setAge("31");
a2.setName("sasi");
Map<String,A> m
浏览 0提问于2018-05-04得票数 0
我有这样的代码：
myList.stream()
.filter(item -> item.getName().isPresent())
.filter(item -> item.getName().get().equalsIgnoreCase(otherName))
.findFirst();
(...其中item.getName()的返回类型为Optional<String>)
我怎么能在这里把两个过滤器浓缩成一个？
浏览 6提问于2021-06-10得票数 5
回答已采纳
我有一个对象Person，它有两个属性Name和Status。我希望从一个对象列表中筛选出状态为Person的In Progress对象。这是我的代码：
personList.stream().filter(
t -> t.getStatus().equalsIgnoreCase(
"In Progress")).collect(Collectors.toList());
但是代码正在抛出一个nullpointerexception错误。当我检查时，我发现有几个具有In Progress状态的对象具有空值。在兰博达我们该怎么处理呢？
浏览 1提问于2017-10-26得票数 21
回答已采纳
我有一个class A，它的id类型为String，还有一个子列表，它与父类(A类)的类型相同，但是子类可以是空的，或者子类列表可以是空的。给定一个id，需要使用java8流从列表中找到与父对象id或子对象id相匹配的对象。 我有下面的代码，它返回父对象，即使id与子对象相匹配。我需要子对象。 Optional<A> a = mylist.stream()
.filter(f -> f.getId().equalsIgnoreCase(id) ||
f.getChildren().anyMatch(f2 -> f2.getId
浏览 28提问于2020-10-10得票数 1
回答已采纳
2回答
我有如下的employee和address类 class Employee {
private String name;
private int age;
private List<Address> addresses;
//getter and setter
}
class Address {
private String city;
private String state;
private String country;
//getter and setter
} 使用java 8过滤器，我想打印城市以P开头
浏览 13提问于2019-12-12得票数 5
回答已采纳
1回答
我试图了解如何更好地有条件地将流输送到Transform或类似的，而无需使用第三方库()。
理想情况下，我想做这样的事情
const transformA, transformB = // my transforms
const booleanA, booleanB = // my various conditions
const stream = new Readable()
stream.push('...') // my content
return stream
.pipe(booleanA && transformA)
浏览 1提问于2020-05-12得票数 0
回答已采纳
我正在尝试将以下Java代码转换为Java 8。我编写了以下代码来计算平均温度。
public static double calculateTemps(String country, Map<String, List<Temperatures>> tempMap) {
double temp = 0.0f;
int count = 0;
if (country.equalsIgnoreCase("India")) {
for (Map.Entry<String, List<Temperatures&
浏览 6提问于2022-07-15得票数 -1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
