com.opendatagroup.hadrian

data

package data

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. data
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. trait AnyPFAEnumSymbol extends AnyRef

  2. trait AnyPFAFixed extends AnyRef

  3. trait AnyPFARecord extends AnyRef

  4. class AvroDataTranslator extends AnyRef

  5. class AvroOutputDataStream extends DataFileWriter[AnyRef] with OutputDataStream

  6. class Comparison extends (AnyRef, AnyRef) ⇒ Int

  7. class ComparisonMax extends AnyRef

  8. class ComparisonMin extends AnyRef

  9. class ComparisonOperator extends (AnyRef, AnyRef) ⇒ Boolean

  10. class ComparisonOperatorLT extends (AnyRef, AnyRef) ⇒ Boolean

  11. class CsvOutputDataStream extends OutputDataStream

  12. class GenericComparisonMax extends AnyRef

  13. class GenericComparisonMin extends AnyRef

  14. class GenericPFADatumReader[X] extends GenericDatumReader[X]

  15. class GenericPFADatumWriter[X] extends GenericDatumWriter[X]

  16. class GenericPFAEnumSymbol extends EnumSymbol with AnyPFAEnumSymbol

  17. class GenericPFAFixed extends Fixed with AnyPFAFixed

  18. class GenericPFARecord extends Record with AnyPFARecord

  19. class JsonOutputDataStream extends OutputDataStream

  20. trait OutputDataStream extends AnyRef

  21. class PFAArray[X] extends List[X]

  22. class PFADataTranslator extends AnyRef

  23. class PFADatumReader[X] extends SpecificDatumReader[X]

  24. class PFADatumWriter[X] extends SpecificDatumWriter[X]

  25. abstract class PFAEnumSymbol extends AnyPFAEnumSymbol

  26. abstract class PFAFixed extends SpecificFixed with AnyPFAFixed

  27. class PFAGenericData extends GenericData

  28. class PFAMap[X <: AnyRef] extends Map[String, X]

  29. abstract class PFARecord extends SpecificRecordBase with AnyPFARecord

  30. class PFASpecificData extends SpecificData

  31. class ScalaDataTranslator[X] extends AnyRef

Value Members

  1. object AvroDataTranslator

  2. object NumericalComparison

  3. object NumericalEQ

  4. object NumericalGE

  5. object NumericalGT

  6. object NumericalLE

  7. object NumericalLT

  8. object NumericalMax

  9. object NumericalMin

  10. object NumericalNE

  11. object PFAArray

  12. object PFADataTranslator

  13. object PFAMap

  14. object ScalaDataTranslator

  15. def avroInputIterator[X](inputStream: InputStream, inputType: AvroType): DataFileStream[X]

  16. def avroOutputDataStream(fileName: String, outputType: AvroType): AvroOutputDataStream

  17. def avroOutputDataStream(file: File, outputType: AvroType): AvroOutputDataStream

  18. def avroOutputDataStream(outputStream: OutputStream, outputType: AvroType): AvroOutputDataStream

  19. 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]

  20. def csvOutputDataStream(outputStream: OutputStream, outputType: AvroType, csvFormat: CSVFormat = ..., writeHeader: Boolean = true): CsvOutputDataStream

  21. def fromAvro(avro: Array[Byte], avroType: AvroType): AnyRef

  22. def fromAvro(avro: Array[Byte], schema: Schema): AnyRef

  23. def fromJson(json: String, avroType: AvroType): AnyRef

  24. def fromJson(json: String, schema: Schema): AnyRef

  25. val genericData: PFAGenericData

  26. def jsonInputIterator[X](inputIterator: Iterator[String], inputType: AvroType): Iterator[X]

  27. def jsonInputIterator[X](inputIterator: Iterator[String], inputType: AvroType): Iterator[X]

  28. def jsonInputIterator[X](inputStream: InputStream, inputType: AvroType): Iterator[X]

  29. def jsonOutputDataStream(fileName: String, outputType: AvroType, writeSchema: Boolean): JsonOutputDataStream

  30. def jsonOutputDataStream(file: File, outputType: AvroType, writeSchema: Boolean): JsonOutputDataStream

  31. def jsonOutputDataStream(outputStream: OutputStream, outputType: AvroType, writeSchema: Boolean): JsonOutputDataStream

  32. def toAvro(obj: AnyRef, avroType: AvroType): Array[Byte]

  33. def toAvro(obj: AnyRef, schema: Schema): Array[Byte]

  34. def toJson(obj: AnyRef, avroType: AvroType): String

  35. def toJson(obj: AnyRef, schema: Schema): String

  36. def toJsonDom(obj: AnyRef, avroType: AvroType): JsonDom

Inherited from AnyRef

Inherited from Any

Ungrouped