com
.
opendatagroup
.
hadrian
.
jvmcompiler
PFAEngineBase
abstract
class
PFAEngineBase
extends
AnyRef
Linear Supertypes
AnyRef
,
Any
Ordering
Alphabetic
By inheritance
Inherited
PFAEngineBase
AnyRef
Any
Hide All
Show all
Learn more about member selection
Visibility
Public
All
Instance Constructors
new
PFAEngineBase
()
Abstract Value Members
abstract
def
checkClock
()
:
Unit
abstract
val
classLoader
:
ClassLoader
abstract
def
getRunlock
:
AnyRef
Concrete 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
var
_actionsFinished
:
Long
var
_actionsStarted
:
Long
var
_inputClass
:
Class
[
AnyRef
]
var
_instance
:
Int
var
_metadata
:
PFAMap
[
String
]
var
_outputClass
:
Class
[
AnyRef
]
def
actionsFinished
:
Long
def
actionsStarted
:
Long
def
analyzeCell
[
X
]
(
name:
String
,
analysis: (
Any
) ⇒
X
)
:
X
def
analyzePool
[
X
]
(
name:
String
,
analysis: (
Any
) ⇒
X
)
:
Map
[
String
,
X
]
final
def
asInstanceOf
[
T0
]
:
T0
Definition Classes
Any
def
avroInputIterator
[
X <:
AnyRef
]
(
inputStream:
InputStream
)
:
DataFileStream
[
X
]
def
avroOutputDataStream
(
fileName:
String
)
:
AvroOutputDataStream
def
avroOutputDataStream
(
file:
File
)
:
AvroOutputDataStream
def
avroOutputDataStream
(
outputStream:
OutputStream
)
:
AvroOutputDataStream
def
callDepth
(
fcnName:
String
,
exclude:
Set
[
String
] =
Set[String]()
,
startingDepth:
Double
=
0
)
:
Double
def
callGraph
:
Map
[
String
,
Set
[
String
]]
def
calledBy
(
fcnName:
String
,
exclude:
Set
[
String
] =
Set[String]()
)
:
Set
[
String
]
val
cellsToRollback
:
Map
[
String
,
Field
]
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
def
config
:
EngineConfig
def
csvInputIterator
[
X <:
AnyRef
]
(
inputStream:
InputStream
,
csvFormat:
CSVFormat
=
CSVFormat.DEFAULT.withHeader()
)
:
Iterator
[
X
]
def
csvOutputDataStream
(
outputStream:
OutputStream
,
csvFormat:
CSVFormat
=
...
,
writeHeader:
Boolean
=
true
)
:
CsvOutputDataStream
def
datumReader
[
INPUT <:
AnyRef
]
:
DatumReader
[
INPUT
]
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
equals
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
def
finalize
()
:
Unit
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
classOf[java.lang.Throwable]
)
def
fromAvro
(
avro:
Array
[
Byte
]
,
avroType:
AvroType
)
:
AnyRef
def
fromAvro
(
avro:
Array
[
Byte
]
,
schema:
Schema
)
:
AnyRef
def
fromGenericAvroData
[
INPUT <:
AnyRef
]
(
datum:
AnyRef
)
:
INPUT
def
fromJson
(
json:
Array
[
Byte
]
,
avroType:
AvroType
)
:
AnyRef
def
fromJson
(
json:
Array
[
Byte
]
,
schema:
Schema
)
:
AnyRef
def
fromPFAData
[
INPUT <:
AnyRef
]
(
datum:
AnyRef
)
:
INPUT
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
def
hasRecursive
(
fcnName:
String
)
:
Boolean
def
hasSideEffects
(
fcnName:
String
)
:
Boolean
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
def
initialize
(
config:
EngineConfig
,
options:
EngineOptions
,
sharedState:
Option
[
SharedState
]
,
thisClass:
Class
[_]
,
context:
Context
,
index:
Int
)
:
Unit
def
inputClass
:
Class
[
AnyRef
]
def
inputType
:
AvroType
def
instance
:
Int
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
def
isRecursive
(
fcnName:
String
)
:
Boolean
def
jsonInput
[
INPUT <:
AnyRef
]
(
json:
String
)
:
INPUT
def
jsonInput
[
INPUT <:
AnyRef
]
(
json:
Array
[
Byte
]
)
:
INPUT
def
jsonInputIterator
[
X <:
AnyRef
]
(
inputIterator:
Iterator
[
String
]
)
:
Iterator
[
X
]
def
jsonInputIterator
[
X <:
AnyRef
]
(
inputIterator:
Iterator
[
String
]
)
:
Iterator
[
X
]
def
jsonInputIterator
[
X <:
AnyRef
]
(
inputStream:
InputStream
)
:
Iterator
[
X
]
def
jsonOutput
[
OUTPUT <:
AnyRef
]
(
obj:
OUTPUT
)
:
String
def
jsonOutputDataStream
(
fileName:
String
,
writeSchema:
Boolean
)
:
JsonOutputDataStream
def
jsonOutputDataStream
(
file:
File
,
writeSchema:
Boolean
)
:
JsonOutputDataStream
def
jsonOutputDataStream
(
outputStream:
OutputStream
,
writeSchema:
Boolean
)
:
JsonOutputDataStream
var
log
: (
String
,
Option
[
String
]) ⇒
Unit
def
method
:
Method
def
namedTypes
:
Map
[
String
,
AvroType
]
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
def
options
:
EngineOptions
def
outputClass
:
Class
[
AnyRef
]
def
outputType
:
AvroType
val
poolsToRollback
:
Map
[
String
,
Field
]
def
randomGenerator
:
Random
def
revert
(
sharedState:
Option
[
SharedState
]
)
:
Unit
def
revert
()
:
Unit
def
rollback
()
:
Unit
def
rollbackSave
()
:
Unit
val
savedCells
:
Map
[
String
,
Any
]
val
savedPools
:
Map
[
String
,
HashMap
[
String
,
AnyRef
]]
def
snapshot
()
:
EngineConfig
def
snapshotCell
(
name:
String
)
:
AnyRef
def
snapshotPool
(
name:
String
)
:
Map
[
String
,
AnyRef
]
val
specificData
:
PFASpecificData
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toAvro
(
obj:
AnyRef
,
avroType:
AvroType
)
:
Array
[
Byte
]
def
toAvro
(
obj:
AnyRef
,
schema:
Schema
)
:
Array
[
Byte
]
def
toJson
(
obj:
AnyRef
,
avroType:
AvroType
)
:
String
def
toJson
(
obj:
AnyRef
,
schema:
Schema
)
:
String
def
toString
()
:
String
Definition Classes
AnyRef → Any
def
typeParser
:
ForwardDeclarationParser
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
AnyRef
Inherited from
Any
Ungrouped