com
.
collective
.
modelmatrix
.
cli
.
instance
AddInstance
case class
AddInstance
(
modelDefinitionId:
Int
,
source:
Source
,
name:
Option
[
String
]
,
comment:
Option
[
String
]
,
concurrencyLevel:
Int
,
repartitionSource:
Option
[
Int
]
,
cacheSource:
Boolean
)
extends
Script
with
SourceTransformation
with
PostgresModelMatrixCatalog
with
CliSparkContext
with
Transformers
with
TransformationProcess
with
Product
with
Serializable
Linear Supertypes
Serializable
,
Serializable
,
Product
,
Equals
,
TransformationProcess
,
transform.Transformers
,
CliSparkContext
,
PostgresModelMatrixCatalog
,
ModelMatrixCatalogAccess
,
SourceTransformation
,
Script
,
AnyRef
,
Any
Ordering
Alphabetic
By inheritance
Inherited
AddInstance
Serializable
Serializable
Product
Equals
TransformationProcess
Transformers
CliSparkContext
PostgresModelMatrixCatalog
ModelMatrixCatalogAccess
SourceTransformation
Script
AnyRef
Any
Hide All
Show all
Learn more about member selection
Visibility
Public
All
Instance Constructors
new
AddInstance
(
modelDefinitionId:
Int
,
source:
Source
,
name:
Option
[
String
]
,
comment:
Option
[
String
]
,
concurrencyLevel:
Int
,
repartitionSource:
Option
[
Int
]
,
cacheSource:
Boolean
)
Type Members
trait
ModelMatrixTransformation
extends
AnyRef
Definition Classes
TransformationProcess
class
Transformers
extends
AnyRef
Attributes
protected
Definition Classes
Transformers
Value Members
final
def
!=
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
!=
(
arg0:
Any
)
:
Boolean
Definition Classes
Any
final
def
##
()
:
Int
Definition Classes
AnyRef → Any
final
def
==
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
==
(
arg0:
Any
)
:
Boolean
Definition Classes
Any
def
as
[
T
]
:
T
Definition Classes
Script
final
def
asInstanceOf
[
T0
]
:
T0
Definition Classes
Any
def
blockOn
[
T
]
(
f:
Future
[
T
]
,
duration:
FiniteDuration
=
10.seconds
)
:
T
Attributes
protected
Definition Classes
ModelMatrixCatalogAccess
val
cacheSource
:
Boolean
Definition Classes
AddInstance
→
SourceTransformation
lazy val
catalog
:
ModelMatrixCatalog
Attributes
protected
Definition Classes
PostgresModelMatrixCatalog
implicit
val
catalogExecutionContext
:
@@
[
ExecutionContext
,
ModelMatrixCatalog
]
Attributes
protected
Definition Classes
ModelMatrixCatalogAccess
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
val
comment
:
Option
[
String
]
def
computeModelMatrixTransformation
(
features:
Seq
[(
ModelDefinitionFeature
,
TypedModelFeature
)]
,
concurrencyLevel:
Int
)
(
implicit
t:
Transformers
)
:
Task
[
ModelMatrixTransformation
]
Attributes
protected
Definition Classes
TransformationProcess
val
concurrencyLevel
:
Int
lazy val
db
:
Database
Attributes
protected
Definition Classes
PostgresModelMatrixCatalog
→
ModelMatrixCatalogAccess
val
driver
:
PostgresDriver
.type
Attributes
protected
Definition Classes
PostgresModelMatrixCatalog
→
ModelMatrixCatalogAccess
implicit
val
ec
:
ExecutionContext
Definition Classes
TransformationProcess
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
finalize
()
:
Unit
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
classOf[java.lang.Throwable]
)
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
lazy val
modelDefinitionFeatures
:
ModelDefinitionFeatures
Attributes
protected
Definition Classes
PostgresModelMatrixCatalog
→
ModelMatrixCatalogAccess
val
modelDefinitionId
:
Int
lazy val
modelDefinitions
:
ModelDefinitions
Attributes
protected
Definition Classes
PostgresModelMatrixCatalog
→
ModelMatrixCatalogAccess
lazy val
modelInstanceFeatures
:
ModelInstanceFeatures
Attributes
protected
Definition Classes
PostgresModelMatrixCatalog
→
ModelMatrixCatalogAccess
lazy val
modelInstances
:
ModelInstances
Attributes
protected
Definition Classes
PostgresModelMatrixCatalog
→
ModelMatrixCatalogAccess
val
name
:
Option
[
String
]
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
val
repartitionSource
:
Option
[
Int
]
Definition Classes
AddInstance
→
SourceTransformation
def
run
()
:
Unit
Definition Classes
AddInstance
→
Script
lazy val
sc
:
SparkContext
Definition Classes
CliSparkContext
val
source
:
Source
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toDataFrame
(
source:
Source
)
(
implicit
sqlContext:
SQLContext
)
:
DataFrame
Attributes
protected
Definition Classes
SourceTransformation
final
def
wait
()
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
,
arg1:
Int
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
Inherited from
Serializable
Inherited from
Serializable
Inherited from
Product
Inherited from
Equals
Inherited from
TransformationProcess
Inherited from
transform.Transformers
Inherited from
CliSparkContext
Inherited from
PostgresModelMatrixCatalog
Inherited from
ModelMatrixCatalogAccess
Inherited from
SourceTransformation
Inherited from
Script
Inherited from
AnyRef
Inherited from
Any
Ungrouped