com.cloudera.oryx.lambda.batch

Class BatchLayer<K,M,U>

java.lang.Object

com.cloudera.oryx.lambda.AbstractSparkLayer<K,M>

com.cloudera.oryx.lambda.batch.BatchLayer<K,M,U>

Type Parameters:

K - type of key read from input topic

M - type of message read from input topic

U - type of model message written

All Implemented Interfaces:

Closeable, AutoCloseable

public final class BatchLayer<K,M,U>
extends AbstractSparkLayer<K,M>

Main entry point for Oryx Batch Layer.

Constructor Summary

Constructors

Constructor and Description
BatchLayer(com.typesafe.config.Config config)

Method Summary

Modifier and Type	Method and Description
void	await()
void	close()
protected String	getConfigGroup()
protected String	getLayerName()
void	start()

Methods inherited from class com.cloudera.oryx.lambda.AbstractSparkLayer

buildInputDStream, buildStreamingContext, getConfig, getGroupID, getID, getInputTopicLockMaster, getKeyClass, getMessageClass

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchLayer

public BatchLayer(com.typesafe.config.Config config)

Method Detail

getConfigGroup

protected String getConfigGroup()

Specified by:

getConfigGroup in class AbstractSparkLayer<K,M>

Returns:

layer-specific config grouping under "oryx", like "batch" or "speed"

getLayerName

protected String getLayerName()

Specified by:

getLayerName in class AbstractSparkLayer<K,M>

Returns:

display name for layer like "BatchLayer"

start

public void start()

await

public void await()
           throws InterruptedException

Throws:

InterruptedException

close

public void close()