Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 25 of 25 for flatMap (0.03 sec)

  1. docs/bigdata/README.md

    ```
    scala> val file = sc.textFile("s3a://testbucket/testdata")
    file: org.apache.spark.rdd.RDD[String] = s3a://testbucket/testdata MapPartitionsRDD[1] at textFile at <console>:24
    
    scala> val counts = file.flatMap(line => line.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)
    counts: org.apache.spark.rdd.RDD[(String, Int)] = ShuffledRDD[4] at reduceByKey at <console>:25
    
    scala> counts.saveAsTextFile("s3a://testbucket/wordcount")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ImmutableMultimap.java

             */
            return immutableEntry(requireNonNull(currentKey), valueItr.next());
          }
        };
      }
    
      @Override
      Spliterator<Entry<K, V>> entrySpliterator() {
        return CollectSpliterators.flatMap(
            asMap().entrySet().spliterator(),
            keyToValueCollectionEntry -> {
              K key = keyToValueCollectionEntry.getKey();
              Collection<V> valueCollection = keyToValueCollectionEntry.getValue();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 28.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/StandardTable.java

            rowIterator.remove();
            rowEntry = null;
          }
        }
      }
    
      @Override
      Spliterator<Cell<R, C, V>> cellSpliterator() {
        return CollectSpliterators.flatMap(
            backingMap.entrySet().spliterator(),
            (Entry<R, Map<C, V>> rowEntry) ->
                CollectSpliterators.map(
                    rowEntry.getValue().entrySet().spliterator(),
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 30.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java

                                    HashMap::putAll));
                }
                propMap.put(DEFAULT_LABEL_VALUES, map);
            }
            return map.entrySet().stream().flatMap(e -> {
                final String key = e.getKey();
                if (StringUtil.isEmpty(key) || userBean
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 86.5K bytes
    - Viewed (0)
  5. api/maven-api-spi/src/main/java/org/apache/maven/api/spi/PackagingProvider.java

     * public class CustomPackagingProvider implements PackagingProvider {
     *     public Collection&lt;Packaging&gt; provides() {
     *         return Arrays.asList(
     *             packaging("docker-image"),
     *             packaging("flatpak")
     *         );
     *     }
     * }
     * </pre>
     *
     * @see org.apache.maven.api.Packaging
     * @see org.apache.maven.api.spi.ExtensibleEnumProvider
     * @since 4.0.0
     */
    @Experimental
    @Consumer
    @Named
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Apr 03 13:33:59 UTC 2025
    - 2K bytes
    - Viewed (0)
Back to top