Package com.c12e.cortex.profiles.streamWriter

Class DefaultCortexSparkStreamWriter

java.lang.Object

com.c12e.cortex.profiles.streamWriter.DefaultCortexSparkStreamWriter

All Implemented Interfaces:

CortexSparkStreamWriter

public class DefaultCortexSparkStreamWriter
extends java.lang.Object
implements CortexSparkStreamWriter

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultCortexSparkStreamWriter(CortexDataSourceStreamWriterModule cortexDataSourceStreamWriterModule)

Method Summary

Modifier and Type	Method	Description
CortexDataSourceStreamWriter	writeDataSource(CortexDataSourcePair dsPair, java.lang.String project, java.lang.String dataSourceName)	Retrieve a builder for writing a streaming dataset to a DataSource

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCortexSparkStreamWriter

@Inject
protected DefaultCortexSparkStreamWriter(CortexDataSourceStreamWriterModule cortexDataSourceStreamWriterModule)

Method Detail

writeDataSource

public CortexDataSourceStreamWriter writeDataSource(CortexDataSourcePair dsPair,
                                                    java.lang.String project,
                                                    java.lang.String dataSourceName)

Retrieve a builder for writing a streaming dataset to a DataSource

Specified by:

writeDataSource in interface CortexSparkStreamWriter

Parameters:

dsPair - - the DataFrame pair retrieved with CortexSparkStreamReader.readConnection(String, String)

project - - the DataSource project

dataSourceName - - the DataSource name

Returns:

the stream writer builder