Package com.hazelcast.vector.jet

Class VectorSinks

java.lang.Object
com.hazelcast.vector.jet.VectorSinks
@Beta public final class VectorSinks extends Object
Factory methods for Vector collection sinks
Since:
5.5

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T, K, V> com.hazelcast.jet.pipeline.Sink<T>
    vectorCollection(VectorCollection<K,V> collection, com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, com.hazelcast.function.FunctionEx<? super T,? extends V> toValueFn, com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorValues> toVectorsFn)
    Returns a sink that writes vector documents with metadata and vector values to a vector collection.
    static <T, K, V> com.hazelcast.jet.pipeline.Sink<T>
    vectorCollection(VectorCollection<K,V> collection, com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorDocument<? extends V>> toDocumentFn)
    Returns a sink that writes vector documents with metadata and vector values to a vector collection.
    static <T, K, V> com.hazelcast.jet.pipeline.Sink<T>
    vectorCollection(String collectionName, com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, com.hazelcast.function.FunctionEx<? super T,? extends V> toValueFn, com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorValues> toVectorsFn)
    Returns a sink that writes vector documents with metadata and vector values to a vector collection.
    static <T, K, V> com.hazelcast.jet.pipeline.Sink<T>
    vectorCollection(String collectionName, com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorDocument<? extends V>> toDocumentFn)
    Returns a sink that writes vector documents with metadata and vector values to a vector collection.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • vectorCollection

      @Nonnull public static <T, K, V> com.hazelcast.jet.pipeline.Sink<T> vectorCollection(@Nonnull VectorCollection<K,V> collection, @Nonnull com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, @Nonnull com.hazelcast.function.FunctionEx<? super T,? extends V> toValueFn, @Nonnull com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorValues> toVectorsFn)
      Returns a sink that writes vector documents with metadata and vector values to a vector collection.

      This sink internally limits number of parallel requests to not overload the members.

      Type Parameters:
      T - type of stream item
      K - type of vector collection key
      V - type of vector collection value
      Parameters:
      collection - vector collection
      toKeyFn - function that extracts the key from the stream item
      toValueFn - function that extracts the value from the stream item
      toVectorsFn - function that extracts the vectors from the stream item

    • vectorCollection

      @Nonnull public static <T, K, V> com.hazelcast.jet.pipeline.Sink<T> vectorCollection(@Nonnull VectorCollection<K,V> collection, @Nonnull com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, @Nonnull com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorDocument<? extends V>> toDocumentFn)
      Returns a sink that writes vector documents with metadata and vector values to a vector collection.

      This sink internally limits number of parallel requests to not overload the members.

      Type Parameters:
      T - type of stream item
      K - type of vector collection key
      V - type of vector collection value
      Parameters:
      collection - vector collection
      toKeyFn - function that extracts the key from the stream item
      toDocumentFn - function that creates VectorDocument based on the stream item

    • vectorCollection

      @Nonnull public static <T, K, V> com.hazelcast.jet.pipeline.Sink<T> vectorCollection(@Nonnull String collectionName, @Nonnull com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, @Nonnull com.hazelcast.function.FunctionEx<? super T,? extends V> toValueFn, @Nonnull com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorValues> toVectorsFn)
      Returns a sink that writes vector documents with metadata and vector values to a vector collection.

      This sink internally limits number of parallel requests to not overload the members.

      Type Parameters:
      T - type of stream item
      K - type of vector collection key
      V - type of vector collection value
      Parameters:
      collectionName - vector collection name
      toKeyFn - function that extracts the key from the stream item
      toValueFn - function that extracts the value from the stream item
      toVectorsFn - function that extracts the vectors from the stream item

    • vectorCollection

      @Nonnull public static <T, K, V> com.hazelcast.jet.pipeline.Sink<T> vectorCollection(@Nonnull String collectionName, @Nonnull com.hazelcast.function.FunctionEx<? super T,? extends K> toKeyFn, @Nonnull com.hazelcast.function.FunctionEx<? super T,com.hazelcast.vector.VectorDocument<? extends V>> toDocumentFn)
      Returns a sink that writes vector documents with metadata and vector values to a vector collection.

      This sink internally limits number of parallel requests to not overload the members.

      Type Parameters:
      T - type of stream item
      K - type of vector collection key
      V - type of vector collection value
      Parameters:
      collectionName - vector collection name
      toKeyFn - function that extracts the key from the stream item
      toDocumentFn - function that creates VectorDocument based on the stream item