public class MatrixVectorMul extends Object
The input is a vector stream, 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.