Class DefaultCortexProfileWriter
- java.lang.Object
-
- com.c12e.cortex.profiles.module.profile.DefaultCortexProfileWriter
-
- All Implemented Interfaces:
CortexModule<CortexProfileWriter>
,CortexProfileWriterModule
public class DefaultCortexProfileWriter extends java.lang.Object implements CortexProfileWriterModule
Default implementation of CortexProfileWriterModule
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
DefaultCortexProfileWriter.CortexWriteParameters
-
Constructor Summary
Constructors Modifier Constructor Description protected
DefaultCortexProfileWriter(com.c12e.cortex.phoenix.Catalog catalog, CortexValidator validator, FeatureCatalog featureCatalog, PhoenixRemoteStorage phoenixRemoteStorage, CortexConnectionWriterModule cortexConnectionWriterModule)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CortexProfileWriter
getBuilder()
Create module specific builderprotected com.c12e.cortex.phoenix.ProfileSchema
getProfileSchema(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters)
protected com.c12e.cortex.phoenix.Connection
getWriteConnection(java.lang.String project, java.lang.String profileSchemaName)
protected void
validateDataSet(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters, com.c12e.cortex.phoenix.ProfileSchema profileSchema)
void
write(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters)
Write to a CortexProfileSchema
using the builder instanceprotected void
writeToProfileSchema(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters, com.c12e.cortex.phoenix.Connection phoenixProfileConnection)
-
-
-
Constructor Detail
-
DefaultCortexProfileWriter
@Inject protected DefaultCortexProfileWriter(com.c12e.cortex.phoenix.Catalog catalog, CortexValidator validator, FeatureCatalog featureCatalog, PhoenixRemoteStorage phoenixRemoteStorage, CortexConnectionWriterModule cortexConnectionWriterModule)
-
-
Method Detail
-
getProfileSchema
protected com.c12e.cortex.phoenix.ProfileSchema getProfileSchema(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters)
-
validateDataSet
protected void validateDataSet(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters, com.c12e.cortex.phoenix.ProfileSchema profileSchema)
-
getWriteConnection
protected com.c12e.cortex.phoenix.Connection getWriteConnection(java.lang.String project, java.lang.String profileSchemaName)
-
writeToProfileSchema
protected void writeToProfileSchema(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters, com.c12e.cortex.phoenix.Connection phoenixProfileConnection)
-
write
public void write(DefaultCortexProfileWriter.CortexWriteParameters cortexWriteParameters)
Write to a CortexProfileSchema
using the builder instance- Parameters:
cortexWriteParameters
- builder instance
-
getBuilder
public CortexProfileWriter getBuilder()
Description copied from interface:CortexModule
Create module specific builder- Specified by:
getBuilder
in interfaceCortexModule<CortexProfileWriter>
- Returns:
- builder instance
-
-