org.deeplearning4j.streaming.kafka

Class NDArrayPublisher

java.lang.Object

org.deeplearning4j.streaming.kafka.NDArrayPublisher

public class NDArrayPublisher
extends java.lang.Object

Send an ndarray to a kafka topic

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
NDArrayPublisher()

Method Summary

Modifier and Type	Method and Description
void	publish(org.nd4j.linalg.api.ndarray.INDArray arr) Publish an ndarray
void	publish(org.nd4j.linalg.api.ndarray.INDArray[] arr) Publish an ndarray
void	start() Start the publisher

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

NDARRAY_TYPE

public static final java.lang.String NDARRAY_TYPE

See Also:

Constant Field Values

Constructor Detail

NDArrayPublisher

public NDArrayPublisher()

Method Detail

publish

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

Publish an ndarray

Parameters:

arr - the ndarray to publish

Throws:

java.lang.Exception

publish

public void publish(org.nd4j.linalg.api.ndarray.INDArray arr)
             throws java.lang.Exception

Publish an ndarray

Parameters:

arr - the ndarray to publish

Throws:

java.lang.Exception

start

public void start()
           throws java.lang.Exception

Start the publisher

Throws:

java.lang.Exception