org.deeplearning4j.streaming.kafka

Class NDArrayConsumer

java.lang.Object

org.deeplearning4j.streaming.kafka.NDArrayConsumer

public class NDArrayConsumer
extends java.lang.Object

NDArray consumer for receiving ndarrays off of kafka

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DIRECT_ROUTE

Constructor Summary

Constructors

Constructor and Description
NDArrayConsumer()

Method Summary

Modifier and Type	Method and Description
org.nd4j.linalg.api.ndarray.INDArray[]	getArrays() Receive an ndarray from the queue
org.nd4j.linalg.api.ndarray.INDArray	getINDArray()
void	start() Start the consumer

Methods inherited from class java.lang.Object

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

Field Detail

DIRECT_ROUTE

public static final java.lang.String DIRECT_ROUTE

See Also:

Constant Field Values

Constructor Detail

NDArrayConsumer

public NDArrayConsumer()

Method Detail

start

public void start()
           throws java.lang.Exception

Start the consumer

Throws:

java.lang.Exception

getArrays

public org.nd4j.linalg.api.ndarray.INDArray[] getArrays()
                                                 throws java.lang.Exception

Receive an ndarray from the queue

Returns:

the ndarray to get

Throws:

java.lang.Exception

getINDArray

public org.nd4j.linalg.api.ndarray.INDArray getINDArray()
                                                 throws java.lang.Exception

Throws:

java.lang.Exception