Wgrywam plik do S3 za pomocą Javy - tak mam do tej pory: AmazonS3 s3 = new AmazonS3Client(new BasicAWSCredentials("XX","YY")); List<Bucket> buckets = s3.listBuckets(); s3.putObject(new PutObjectRequest(buckets.get(0).getName(), fileName, stream, new ObjectMetadata())); Plik jest...
To, co chciałbym osiągnąć za pomocą wcięcia lambda, jest następujące: Instrukcja wielowierszowa: String[] ppl = new String[] { "Karen (F)", "Kevin (M)", "Lee (M)", "Joan (F)", "Des (M)", "Rick (M)" }; List<String> strings = Arrays.stream(ppl) .filter( (x) -> { return...
Próbuję zrozumieć, jak zreorganizować program, który wcześniej napisałbym jako sekwencję przejść stanów: Mam logikę biznesową: type In = Long type Count = Int type Out = Count type S = Map[Int, Count] val inputToIn: String => Option[In] = s => try Some(s.toLong) catch { case _ :...
Mam metodę, która oczekuje, że jedna ze zmiennych wejściowych będzie typu java.io.File, ale otrzymuję tylko InputStream. Nie mogę też zmienić podpisu metody. Jak mogę przekonwertować InputStream na typ pliku bez faktycznego zapisywania pliku w systemie plików?
Załóżmy, że mamy klasę Obj class Obj{ int field; } i że masz listę Objinstancji, tj List<Obj> lst. Teraz, jak mogę znaleźć w Java8 strumieniach sumę wartości pól int fieldz obiektów na liście lstpod kryterium filtrowania (np. Dla obiektu okryterium to o.field > 10)?...
Chciałbym wykonać następujące czynności: List<Integer> list = IntStream.range(0, 7).collect(Collectors.toList()); ale w taki sposób, że wynikowa lista jest implementacją guawy ImmutableList. Wiem, że mógłbym to zrobić List<Integer> list = IntStream.range(0,...
W aplikacji internetowej Java, załóżmy, że jeśli chcę pobrać InputStream pliku XML, który jest umieszczony w CLASSPATH (tj. W folderze źródeł ), jak mam to zrobić?
Wyobraź sobie, że mam listę pewnych obiektów: List<Student> Muszę wygenerować kolejną listę zawierającą elementy idsz Studentspowyższej listy: List<Integer> Unikając pętli, czy można to osiągnąć za pomocą kolekcji apache lub guawy ? Które metody powinny być przydatne w moim...
Koduję program, który czyta dane bezpośrednio z danych wejściowych użytkownika i zastanawiałem się, jak mogę (bez pętli) odczytać wszystkie dane do EOF ze standardowego wejścia. Rozważałem użycie, cin.get( input, '\0' )ale '\0'tak naprawdę nie jest to znak EOF, który czyta tylko do EOF lub '\0',...
Mam następującą sytuację Map<Key, ListContainer> map; public class ListContainer{ List<AClass> lst; } Muszę scalić wszystkie listy lstz ListContainerobiektów z Mapmapy. public static void main(String args[]){ List<AClass> alltheObjectsAClass = map.values().stream(). //...
Próbuję odczytać plik podany w NSURLi załadować go do tablicy, z elementami oddzielonymi znakiem nowego wiersza \n. Oto sposób, w jaki zrobiłem to do tej pory: var possList: NSString? = NSString.stringWithContentsOfURL(filePath.URL) as? NSString if var list = possList { list =...
Wygląda na to, że mam problem ze zrozumieniem, w jaki sposób Java komponuje operacje strumieniowe do potoku strumieniowego. Podczas wykonywania następującego kodu public static void main(String[] args) { StringBuilder sb = new StringBuilder(); var count = Stream.of(new String[]{"1", "2",...
Mam trochę kodu Java, który zapewnia obiekty z items. Ogranicza je na podstawie maxNumber: items.stream() .map(this::myMapper) .filter(item -> item != null) .limit(maxNumber) .collect(Collectors.toList()); Działa poprawnie, ale pytanie brzmi: Czy istnieje sposób na ominięcie ograniczenia,...
Wygląda na IntStream.iterateto, że jest to tylko lekka, zamówiona wersja IntStream.generate. Czy to prawda? Jeśli nie, jaka jest podstawowa
Próbuję zrozumieć, dlaczego następujący program Java daje OutOfMemoryError, a odpowiedni program bez .parallel(). System.out.println(Stream .iterate(1, i -> i+1) .parallel() .flatMap(n -> Stream.iterate(n, i -> i+n)) .mapToInt(Integer::intValue) .limit(100_000_000) .sum() ); Mam...
std::basic_iosma publicznego konstruktora : explicit basic_ios (std::basic_streambuf<CharT,Traits>* sb); IMO, jedynym powodem, dla którego klasa ma konstruktora publicznego, jest użycie autonomicznej instancji tej klasy w programie. Jeśli klasa istnieje tylko po to, aby inne klasy z niej...
Mam mapę Map<K, V>i moim celem jest usunięcie zduplikowanych wartości i Map<K, V>ponowne wygenerowanie tej samej struktury . W przypadku, gdy wartość duplikatów zostanie znaleziony, musi być wybrany jeden klawisz ( k) z dwóch przycisków ( k1i k1), które utrzymują te wartości, z tego...
Chcę użyć Streamdo równoległego przetwarzania heterogenicznego zestawu zdalnie przechowywanych plików JSON o nieznanej liczbie (liczba plików nie jest znana z góry). Rozmiar plików może się znacznie różnić, od 1 rekordu JSON na plik do 100 000 rekordów w niektórych innych plikach. Rekord JSON w tym...
Próbowałem przekonwertować tablicę int na List i wybrałem nieznaną drogę korzystania z Java 8 Stream i wymyśliłem to Arrays.stream(arr).boxed().collect(Collectors.toList()); Nadal mam trudności z pełnym zrozumieniem tej linii, głównie Dlaczego Collectors.toList()w tym przypadku zwraca interfejs...
Do czyszczenia listy danych stworzyłem metodę, która akceptuje listę danych i listę operacji czyszczenia do wykonania. public <T> List<T> cleanData(List<T> data, List<Function<T, T>> cleanOps) { List<T>dataNew=data.stream().map((str) -> { T cleanData =...