org
.
dsa
.
iot
.
ignition
.
spark
SparkBlockFactory
Related Doc:
package spark
object
SparkBlockFactory
extends
TypeConverters
Spark RX blocks.
Linear Supertypes
TypeConverters
,
AnyRef
,
Any
Ordering
Alphabetic
By Inheritance
Inherited
SparkBlockFactory
TypeConverters
AnyRef
Any
Hide All
Show All
Visibility
Public
All
Value Members
final
def
!=
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
final
def
##
()
:
Int
Definition Classes
AnyRef → Any
final
def
==
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
object
AddFieldsAdapter
extends
TransformerAdapter
[
DataFrame
,
AddFields
]
object
BasicStatsAdapter
extends
TransformerAdapter
[
DataFrame
,
BasicStats
]
object
CacheAdapter
extends
TransformerAdapter
[
DataFrame
,
Cache
]
object
CassandraInputAdapter
extends
AbstractRxBlockAdapter
[
CassandraInput
]
object
CassandraOutputAdapter
extends
TransformerAdapter
[
DataFrame
,
CassandraOutput
]
object
Categories
object
ColumnStatsAdapter
extends
TransformerAdapter
[
DataFrame
,
ColumnStats
]
object
CorrelationAdapter
extends
TransformerAdapter
[
DataFrame
,
Correlation
]
object
CsvFileInputAdapter
extends
AbstractRxBlockAdapter
[
CsvFileInput
]
object
DataGridAdapter
extends
AbstractRxBlockAdapter
[
DataGrid
]
object
DebugOutputAdapter
extends
TransformerAdapter
[
DataFrame
,
DebugOutput
]
object
FilterAdapter
extends
TransformerAdapter
[
DataFrame
,
Filter
]
object
FormulaAdapter
extends
TransformerAdapter
[
DataFrame
,
Formula
]
object
IntersectionAdapter
extends
AbstractRxBlockAdapter
[
Intersection
]
object
JdbcInputAdapter
extends
AbstractRxBlockAdapter
[
JdbcInput
]
object
JdbcOutputAdapter
extends
TransformerAdapter
[
DataFrame
,
JdbcOutput
]
object
JoinAdapter
extends
AbstractRxBlockAdapter
[
Join
]
object
JsonFileInputAdapter
extends
AbstractRxBlockAdapter
[
JsonFileInput
]
object
MongoInputAdapter
extends
AbstractRxBlockAdapter
[
MongoInput
]
object
MongoOutputAdapter
extends
TransformerAdapter
[
DataFrame
,
MongoOutput
]
object
ReduceAdapter
extends
TransformerAdapter
[
DataFrame
,
Reduce
]
object
RegressionAdapter
extends
TransformerAdapter
[
DataFrame
,
Regression
]
object
RepartitionAdapter
extends
TransformerAdapter
[
DataFrame
,
Repartition
]
object
RestClientAdapter
extends
TransformerAdapter
[
DataFrame
,
RestClient
]
object
SQLQueryAdapter
extends
AbstractRxBlockAdapter
[
SQLQuery
]
object
SelectValuesAdapter
extends
TransformerAdapter
[
DataFrame
,
SelectValues
]
object
SetVariablesAdapter
extends
TransformerAdapter
[
DataFrame
,
SetVariables
]
object
TextFileInputAdapter
extends
AbstractRxBlockAdapter
[
TextFileInput
]
object
TextFileOutputAdapter
extends
TransformerAdapter
[
DataFrame
,
TextFileOutput
]
object
TextFolderInputAdapter
extends
AbstractRxBlockAdapter
[
TextFolderInput
]
object
UnionAdapter
extends
AbstractRxBlockAdapter
[
Union
]
implicit
def
anyToAny
(
x:
Any
)
:
Any
Definition Classes
TypeConverters
implicit
def
anyToBoolean
(
x:
Any
)
:
Boolean
Definition Classes
TypeConverters
implicit
def
anyToDataFrame
(
x:
Any
)
:
DataFrame
Definition Classes
TypeConverters
implicit
def
anyToDouble
(
x:
Any
)
:
Double
Definition Classes
TypeConverters
implicit
def
anyToDuration
(
x:
Any
)
:
Duration
Definition Classes
TypeConverters
implicit
def
anyToInt
(
x:
Any
)
:
Int
Definition Classes
TypeConverters
implicit
def
anyToLong
(
x:
Any
)
:
Long
Definition Classes
TypeConverters
implicit
def
anyToMap
(
x:
Any
)
:
Map
[
String
,
Any
]
Definition Classes
TypeConverters
implicit
def
anyToNumber
(
x:
Any
)
:
Number
Definition Classes
TypeConverters
implicit
def
anyToOptBoolean
(
x:
Any
)
:
Option
[
Boolean
]
Definition Classes
TypeConverters
implicit
def
anyToOptDataFrame
(
x:
Any
)
:
Option
[
DataFrame
]
Definition Classes
TypeConverters
implicit
def
anyToOptDouble
(
x:
Any
)
:
Option
[
Double
]
Definition Classes
TypeConverters
implicit
def
anyToOptDuration
(
x:
Any
)
:
Option
[
Duration
]
Definition Classes
TypeConverters
implicit
def
anyToOptInt
(
x:
Any
)
:
Option
[
Int
]
Definition Classes
TypeConverters
implicit
def
anyToOptLong
(
x:
Any
)
:
Option
[
Long
]
Definition Classes
TypeConverters
implicit
def
anyToOptNumber
(
x:
Any
)
:
Option
[
Number
]
Definition Classes
TypeConverters
implicit
def
anyToOptString
(
x:
Any
)
:
Option
[
String
]
Definition Classes
TypeConverters
implicit
def
anyToOptValue
(
x:
Any
)
:
Option
[
Value
]
Definition Classes
TypeConverters
implicit
def
anyToString
(
x:
Any
)
:
String
Definition Classes
TypeConverters
implicit
def
anyToValue
(
x:
Any
)
:
Value
Definition Classes
TypeConverters
final
def
asInstanceOf
[
T0
]
:
T0
Definition Classes
Any
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
equals
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
implicit
def
extBoolean
(
json:
JsonObject
,
key:
String
)
:
Boolean
Definition Classes
TypeConverters
implicit
def
extDialect
(
json:
JsonObject
,
key:
String
)
:
ScriptDialect
Definition Classes
TypeConverters
implicit
def
extDouble
(
json:
JsonObject
,
key:
String
)
:
Double
Definition Classes
TypeConverters
implicit
def
extDuration
(
json:
JsonObject
,
key:
String
)
:
FiniteDuration
Definition Classes
TypeConverters
implicit
def
extInt
(
json:
JsonObject
,
key:
String
)
:
Int
Definition Classes
TypeConverters
implicit
def
extList
(
json:
JsonObject
,
key:
String
)
:
List
[
Any
]
Definition Classes
TypeConverters
implicit
def
extLong
(
json:
JsonObject
,
key:
String
)
:
Long
Definition Classes
TypeConverters
implicit
def
extMap
(
json:
JsonObject
,
key:
String
)
:
Map
[
String
,
Any
]
Definition Classes
TypeConverters
implicit
def
extNumber
(
json:
JsonObject
,
key:
String
)
:
Number
Definition Classes
TypeConverters
implicit
def
extOptBoolean
(
json:
JsonObject
,
key:
String
)
:
Option
[
Boolean
]
Definition Classes
TypeConverters
implicit
def
extOptDouble
(
json:
JsonObject
,
key:
String
)
:
Option
[
Double
]
Definition Classes
TypeConverters
implicit
def
extOptDuration
(
json:
JsonObject
,
key:
String
)
:
Option
[
FiniteDuration
]
Definition Classes
TypeConverters
implicit
def
extOptInt
(
json:
JsonObject
,
key:
String
)
:
Option
[
Int
]
Definition Classes
TypeConverters
implicit
def
extOptLong
(
json:
JsonObject
,
key:
String
)
:
Option
[
Long
]
Definition Classes
TypeConverters
implicit
def
extOptNumber
(
json:
JsonObject
,
key:
String
)
:
Option
[
Number
]
Definition Classes
TypeConverters
implicit
def
extOptString
(
json:
JsonObject
,
key:
String
)
:
Option
[
String
]
Definition Classes
TypeConverters
implicit
def
extString
(
json:
JsonObject
,
key:
String
)
:
String
Definition Classes
TypeConverters
def
finalize
()
:
Unit
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
classOf[java.lang.Throwable]
)
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
implicit
lazy val
sparkRuntime
:
DefaultSparkRuntime
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toString
()
:
String
Definition Classes
AnyRef → Any
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
TypeConverters
Inherited from
AnyRef
Inherited from
Any
Ungrouped
Spark RX blocks.