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
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|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.