Package com.c12e.cortex.profiles.streamReader

Class DefaultCortexSparkStreamReader

java.lang.Object

com.c12e.cortex.profiles.streamReader.DefaultCortexSparkStreamReader

All Implemented Interfaces:

CortexSparkStreamReader

public class DefaultCortexSparkStreamReader
extends java.lang.Object
implements CortexSparkStreamReader

Default implementation with stream reader builder retrieval and mandatory options set.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultCortexSparkStreamReader(CortexConnectionStreamReaderModule cortexConnectionStreamReaderModule)

Method Summary

Modifier and Type	Method	Description
CortexConnectionStreamReader	readConnection(java.lang.String project, java.lang.String connectionName)	Read streaming connection

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCortexSparkStreamReader

@Inject
protected DefaultCortexSparkStreamReader(CortexConnectionStreamReaderModule cortexConnectionStreamReaderModule)

Method Detail

readConnection

public CortexConnectionStreamReader readConnection(java.lang.String project,
                                                   java.lang.String connectionName)

Read streaming connection

Specified by:

readConnection in interface CortexSparkStreamReader

Parameters:

project -

connectionName -

Returns:

the stream reader builder

See Also:

DataSource