com
.
opendatagroup
.
hadrian
data
package
data
Linear Supertypes
AnyRef
,
Any
Ordering
Alphabetic
By inheritance
Inherited
data
AnyRef
Any
Hide All
Show all
Learn more about member selection
Visibility
Public
All
Type Members
trait
AnyPFAEnumSymbol
extends
AnyRef
trait
AnyPFAFixed
extends
AnyRef
trait
AnyPFARecord
extends
AnyRef
class
AvroDataTranslator
extends
AnyRef
class
AvroOutputDataStream
extends
DataFileWriter
[
AnyRef
] with
OutputDataStream
class
Comparison
extends (
AnyRef
,
AnyRef
) ⇒
Int
class
ComparisonMax
extends
AnyRef
class
ComparisonMin
extends
AnyRef
class
ComparisonOperator
extends (
AnyRef
,
AnyRef
) ⇒
Boolean
class
ComparisonOperatorLT
extends (
AnyRef
,
AnyRef
) ⇒
Boolean
class
CsvOutputDataStream
extends
OutputDataStream
class
GenericComparisonMax
extends
AnyRef
class
GenericComparisonMin
extends
AnyRef
class
GenericPFADatumReader
[
X
]
extends
GenericDatumReader
[
X
]
class
GenericPFADatumWriter
[
X
]
extends
GenericDatumWriter
[
X
]
class
GenericPFAEnumSymbol
extends
EnumSymbol
with
AnyPFAEnumSymbol
class
GenericPFAFixed
extends
Fixed
with
AnyPFAFixed
class
GenericPFARecord
extends
Record
with
AnyPFARecord
class
JsonOutputDataStream
extends
OutputDataStream
trait
OutputDataStream
extends
AnyRef
class
PFAArray
[
X
]
extends
List
[
X
]
class
PFADataTranslator
extends
AnyRef
class
PFADatumReader
[
X
]
extends
SpecificDatumReader
[
X
]
class
PFADatumWriter
[
X
]
extends
SpecificDatumWriter
[
X
]
abstract
class
PFAEnumSymbol
extends
AnyPFAEnumSymbol
abstract
class
PFAFixed
extends
SpecificFixed
with
AnyPFAFixed
class
PFAGenericData
extends
GenericData
class
PFAMap
[
X <:
AnyRef
]
extends
Map
[
String
,
X
]
abstract
class
PFARecord
extends
SpecificRecordBase
with
AnyPFARecord
class
PFASpecificData
extends
SpecificData
class
ScalaDataTranslator
[
X
]
extends
AnyRef
Value Members
object
AvroDataTranslator
object
NumericalComparison
object
NumericalEQ
object
NumericalGE
object
NumericalGT
object
NumericalLE
object
NumericalLT
object
NumericalMax
object
NumericalMin
object
NumericalNE
object
PFAArray
object
PFADataTranslator
object
PFAMap
object
ScalaDataTranslator
def
avroInputIterator
[
X
]
(
inputStream:
InputStream
,
inputType:
AvroType
)
:
DataFileStream
[
X
]
def
avroOutputDataStream
(
fileName:
String
,
outputType:
AvroType
)
:
AvroOutputDataStream
def
avroOutputDataStream
(
file:
File
,
outputType:
AvroType
)
:
AvroOutputDataStream
def
avroOutputDataStream
(
outputStream:
OutputStream
,
outputType:
AvroType
)
:
AvroOutputDataStream
def
csvInputIterator
[
X
]
(
inputStream:
InputStream
,
inputType:
AvroType
,
csvFormat:
CSVFormat
=
CSVFormat.DEFAULT.withHeader()
,
makeFieldReaders:
Option
[(
AvroType
,
Map
[
String
,
Int
]) ⇒
Seq
[(
Int
, (
String
) ⇒
AnyRef
)]] =
None
,
makeRecord:
Option
[(
Array
[
AnyRef
]) ⇒
X
] =
None
)
:
Iterator
[
X
]
def
csvOutputDataStream
(
outputStream:
OutputStream
,
outputType:
AvroType
,
csvFormat:
CSVFormat
=
...
,
writeHeader:
Boolean
=
true
)
:
CsvOutputDataStream
def
fromAvro
(
avro:
Array
[
Byte
]
,
avroType:
AvroType
)
:
AnyRef
def
fromAvro
(
avro:
Array
[
Byte
]
,
schema:
Schema
)
:
AnyRef
def
fromJson
(
json:
String
,
avroType:
AvroType
)
:
AnyRef
def
fromJson
(
json:
String
,
schema:
Schema
)
:
AnyRef
val
genericData
:
PFAGenericData
def
jsonInputIterator
[
X
]
(
inputIterator:
Iterator
[
String
]
,
inputType:
AvroType
)
:
Iterator
[
X
]
def
jsonInputIterator
[
X
]
(
inputIterator:
Iterator
[
String
]
,
inputType:
AvroType
)
:
Iterator
[
X
]
def
jsonInputIterator
[
X
]
(
inputStream:
InputStream
,
inputType:
AvroType
)
:
Iterator
[
X
]
def
jsonOutputDataStream
(
fileName:
String
,
outputType:
AvroType
,
writeSchema:
Boolean
)
:
JsonOutputDataStream
def
jsonOutputDataStream
(
file:
File
,
outputType:
AvroType
,
writeSchema:
Boolean
)
:
JsonOutputDataStream
def
jsonOutputDataStream
(
outputStream:
OutputStream
,
outputType:
AvroType
,
writeSchema:
Boolean
)
:
JsonOutputDataStream
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
toJsonDom
(
obj:
AnyRef
,
avroType:
AvroType
)
:
JsonDom
Inherited from
AnyRef
Inherited from
Any
Ungrouped