| Package | Description |
|---|---|
| co.cask.cdap.common.io | |
| co.cask.cdap.format.io |
| Modifier and Type | Method and Description |
|---|---|
T |
DatumReader.read(Decoder decoder,
co.cask.cdap.api.data.schema.Schema sourceSchema) |
| Modifier and Type | Class and Description |
|---|---|
class |
JsonDecoder
A
Decoder that decodes from json using JsonReader. |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
StructuredRecordDatumReader.decode(Decoder decoder,
co.cask.cdap.api.data.schema.Schema schema)
Decodes a value based on the
Schema. |
protected Collection<?> |
StructuredRecordDatumReader.decodeArray(Decoder decoder,
co.cask.cdap.api.data.schema.Schema elementSchema)
Decodes an array with array element of a given
Schema. |
protected Collection<?> |
JsonStructuredRecordDatumReader.decodeArray(Decoder decoder,
co.cask.cdap.api.data.schema.Schema elementSchema) |
protected String |
StructuredRecordDatumReader.decodeEnum(Decoder decoder,
co.cask.cdap.api.data.schema.Schema schema)
Decodes a enum value based on the given
Schema. |
protected String |
JsonStructuredRecordDatumReader.decodeEnum(Decoder decoder,
co.cask.cdap.api.data.schema.Schema schema) |
protected Map<?,?> |
StructuredRecordDatumReader.decodeMap(Decoder decoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema)
Decodes a map.
|
protected Map<?,?> |
JsonStructuredRecordDatumReader.decodeMap(Decoder decoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema) |
protected co.cask.cdap.api.data.format.StructuredRecord |
StructuredRecordDatumReader.decodeRecord(Decoder decoder,
co.cask.cdap.api.data.schema.Schema schema)
Decodes a record.
|
protected co.cask.cdap.api.data.format.StructuredRecord |
JsonStructuredRecordDatumReader.decodeRecord(Decoder decoder,
co.cask.cdap.api.data.schema.Schema schema) |
protected Object |
StructuredRecordDatumReader.decodeUnion(Decoder decoder,
co.cask.cdap.api.data.schema.Schema schema)
Decodes a value from a union.
|
protected Object |
JsonStructuredRecordDatumReader.decodeUnion(Decoder decoder,
co.cask.cdap.api.data.schema.Schema unionSchema) |
co.cask.cdap.api.data.format.StructuredRecord |
StructuredRecordDatumReader.read(Decoder decoder,
co.cask.cdap.api.data.schema.Schema sourceSchema) |
co.cask.cdap.api.data.format.StructuredRecord |
JsonStructuredRecordDatumReader.read(Decoder decoder,
co.cask.cdap.api.data.schema.Schema sourceSchema) |
Copyright © 2018 Cask Data, Inc. Licensed under the Apache License, Version 2.0.