org.deeplearning4j.streaming.routes

Class DL4jServeRouteBuilder

java.lang.Object

org.apache.camel.builder.BuilderSupport

org.apache.camel.builder.RouteBuilder

org.deeplearning4j.streaming.routes.DL4jServeRouteBuilder

All Implemented Interfaces:

org.apache.camel.RoutesBuilder

public class DL4jServeRouteBuilder
extends org.apache.camel.builder.RouteBuilder

Serve results from a kafka queue. The input to the route can either be a pre serialized ndarray or a normal ndarray itself.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.camel.Processor	beforeProcessor
protected boolean	computationGraph
protected java.lang.String	consumingTopic
protected org.apache.camel.Processor	finalProcessor
protected java.lang.String	groupId
protected java.lang.String	kafkaBroker
protected java.lang.String	modelUri
protected java.lang.String	outputUri
protected java.lang.String	zooKeeperHost
protected int	zooKeeperPort

Fields inherited from class org.apache.camel.builder.RouteBuilder

log

Constructor Summary

Constructors

Constructor and Description
DL4jServeRouteBuilder()

Method Summary

Modifier and Type	Method and Description
void	configure() Called on initialization to build the routes using the fluent builder syntax. This is a central method for RouteBuilder implementations to implement the routes using the Java fluent builder syntax.

Methods inherited from class org.apache.camel.builder.RouteBuilder

addRoutes, addRoutesToCamelContext, checkInitialized, configureRest, configureRests, configureRoute, configureRoutes, createContainer, errorHandler, from, from, from, from, fromF, getContext, getRestCollection, getRestConfigurations, getRouteCollection, includeRoutes, intercept, interceptFrom, interceptFrom, interceptSendToEndpoint, onCompletion, onException, onException, populateRests, populateRoutes, rest, rest, restConfiguration, restConfiguration, setErrorHandlerBuilder, setRestCollection, setRouteCollection, toString

Methods inherited from class org.apache.camel.builder.BuilderSupport

bean, bean, bean, bean, body, body, bodyAs, constant, createErrorHandlerBuilder, deadLetterChannel, deadLetterChannel, defaultErrorHandler, endpoint, endpoint, endpoints, endpoints, exceptionMessage, exchangeProperty, faultBody, faultBodyAs, getErrorHandlerBuilder, header, language, loggingErrorHandler, loggingErrorHandler, loggingErrorHandler, loggingErrorHandler, method, method, method, method, noErrorHandler, outBody, outBody, property, regexReplaceAll, regexReplaceAll, sendTo, setContext, setContext, simple, simple, simpleF, simpleF, systemProperty, systemProperty, xpath, xpath

Methods inherited from class java.lang.Object

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

Field Detail

modelUri

protected java.lang.String modelUri

kafkaBroker

protected java.lang.String kafkaBroker

consumingTopic

protected java.lang.String consumingTopic

computationGraph

protected boolean computationGraph

outputUri

protected java.lang.String outputUri

finalProcessor

protected org.apache.camel.Processor finalProcessor

groupId

protected java.lang.String groupId

zooKeeperHost

protected java.lang.String zooKeeperHost

zooKeeperPort

protected int zooKeeperPort

beforeProcessor

protected org.apache.camel.Processor beforeProcessor

Constructor Detail

DL4jServeRouteBuilder

public DL4jServeRouteBuilder()

Method Detail

configure

public void configure()
               throws java.lang.Exception

Called on initialization to build the routes using the fluent builder syntax.

This is a central method for RouteBuilder implementations to implement the routes using the Java fluent builder syntax.

Specified by:

configure in class org.apache.camel.builder.RouteBuilder

Throws:

java.lang.Exception - can be thrown during configuration