s
Artem Astapenko
09/10/2020, 4:03 PMs
John (Airbyte)
Jared Rhizor (Airbyte)
Michel
John (Airbyte)
Michel
John (Airbyte)
James Peterson
12/10/2020, 3:14 AMChristian Franklin
12/14/2020, 10:49 PMcharles
public static void main(String[] args) {
final Stream<Integer> stream = Stream.of(1)
.peek(i -> System.out.println("outer stream"))
.flatMap(i -> {
return Stream.of(1)
.peek(i1 -> System.out.println("middle stream"))
.flatMap(i2 -> {
return Stream.of(1).peek(i3 -> System.out.println("inner stream"))
.onClose(() -> System.out.println("inner stream closed"));
})
.onClose(() -> System.out.println("middle stream closed"));
}).onClose(() -> System.out.println("outer stream closed"));
System.out.println("collection is about to start");
stream.collect(Collectors.toList());
System.out.println("collection is done");
}
s
charles
public static void main(String[] args) {
final List<Integer> integers = List.of(1, 2, 3, 4);
final long count = integers
.stream()
.peek(i -> System.out.println("i = " + i))
.count();
System.out.println("count = " + count);
}
John (Airbyte)
Michel
Jins Kadwood
01/13/2021, 7:15 AMMichel
charles
// this is just the standard way of turning an iterator of unknown size into a stream.
public static <T> Stream<T> toStream(Iterator<T> iterator) {
return StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false);
}
public static void main(String[] args) {
final Stream<Integer> ints1 = Stream.of(1,2,3)
.peek(value -> System.out.println("peek1.value = " + value));
final Stream<Integer> ints2 = Stream.of(1).flatMap(s -> ints1)
.peek(value -> System.out.println("peek2.value = " + value));
final List<Integer> collect = toStream(ints2.iterator())
.peek(value -> System.out.println("peek3.value = " + value))
.collect(Collectors.toList());
System.out.println("collect.size() = " + collect.size());
}
hint: it is probably not what you would assume it is and is likely the culprit of this issue: https://github.com/airbytehq/airbyte/issues/1582.
will put answer in thread.s
Maxime Lavoie
01/15/2021, 10:12 AMdocker-compose up
that I have zero Connectors available under Admin? Do you need to add connectors on a per need basis?ruslan
01/21/2021, 12:38 PMIasonas Tragakis
02/03/2021, 2:53 PMJohn (Airbyte)
Michel
John (Airbyte)
Samuel Gordalina
03/02/2021, 6:24 PMSrini Kadamati
03/08/2021, 6:36 PMs