public class MatrixVectorMul extends Object
The input is a vector stream from a RandomVectorSource
, which will generate random
vectors with specified dimension. The data size of the vector stream could be specified by user.
Each vector will be multiplied with a random dimension * dimension matrix in Multiplier
and the result would be emitted to output.
Usage: MatrixVectorMul [--output <path>] [--dimension <dimension> --data-size <data_size>]
If no parameters are provided, the program is run with default vector dimension 10 and data size 100.
This example shows how to:
Notice that you need to add JCuda natives libraries in your Flink distribution by the following steps:
Constructor and Description |
---|
MatrixVectorMul() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.