|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use PTypeFamily | |
---|---|
org.apache.crunch | Client-facing API and core abstractions. |
org.apache.crunch.contrib.text | |
org.apache.crunch.impl.dist.collect | |
org.apache.crunch.lib.join | Inner and outer joins on collections. |
org.apache.crunch.types | Common functionality for business object serialization. |
org.apache.crunch.types.avro | Business object serialization using Apache Avro. |
org.apache.crunch.types.writable | Business object serialization using Hadoop's Writables framework. |
Uses of PTypeFamily in org.apache.crunch |
---|
Methods in org.apache.crunch that return PTypeFamily | |
---|---|
PTypeFamily |
PCollection.getTypeFamily()
Returns the PTypeFamily of this PCollection . |
Uses of PTypeFamily in org.apache.crunch.contrib.text |
---|
Methods in org.apache.crunch.contrib.text with parameters of type PTypeFamily | ||
---|---|---|
PType<T> |
Extractor.getPType(PTypeFamily ptf)
Returns the PType associated with this data type for the
given PTypeFamily . |
|
static
|
Parse.parse(String groupName,
PCollection<String> input,
PTypeFamily ptf,
Extractor<T> extractor)
Parses the lines of the input PCollection<String> and returns a PCollection<T> using
the given Extractor<T> that uses the given PTypeFamily . |
|
static
|
Parse.parseTable(String groupName,
PCollection<String> input,
PTypeFamily ptf,
Extractor<Pair<K,V>> extractor)
Parses the lines of the input PCollection<String> and returns a PTable<K, V> using
the given Extractor<Pair<K, V>> that uses the given PTypeFamily . |
Uses of PTypeFamily in org.apache.crunch.impl.dist.collect |
---|
Methods in org.apache.crunch.impl.dist.collect that return PTypeFamily | |
---|---|
PTypeFamily |
PCollectionImpl.getTypeFamily()
|
Uses of PTypeFamily in org.apache.crunch.lib.join |
---|
Methods in org.apache.crunch.lib.join with parameters of type PTypeFamily | |
---|---|
static Class<? extends org.apache.hadoop.io.RawComparator> |
JoinUtils.getGroupingComparator(PTypeFamily typeFamily)
|
static Class<? extends org.apache.hadoop.mapreduce.Partitioner> |
JoinUtils.getPartitionerClass(PTypeFamily typeFamily)
|
Uses of PTypeFamily in org.apache.crunch.types |
---|
Methods in org.apache.crunch.types that return PTypeFamily | |
---|---|
PTypeFamily |
PType.getFamily()
Returns the PTypeFamily that this PType belongs to. |
PTypeFamily |
PGroupedTableType.getFamily()
|
Methods in org.apache.crunch.types with parameters of type PTypeFamily | ||
---|---|---|
static PType<BigInteger> |
PTypes.bigInt(PTypeFamily typeFamily)
A PType for Java's BigInteger type. |
|
static
|
PTypeUtils.convert(PType<T> ptype,
PTypeFamily tf)
|
|
static
|
PTypes.enums(Class<T> type,
PTypeFamily typeFamily)
Constructs a PType for a Java Enum type. |
|
static
|
PTypes.jsonString(Class<T> clazz,
PTypeFamily typeFamily)
Constructs a PType for reading a Java type from a JSON string using Jackson's ObjectMapper . |
|
static
|
PTypes.protos(Class<T> clazz,
PTypeFamily typeFamily)
Constructs a PType for the given protocol buffer. |
|
static
|
PTypes.protos(Class<T> clazz,
PTypeFamily typeFamily,
SerializableSupplier<com.google.protobuf.ExtensionRegistry> supplier)
Constructs a PType for a protocol buffer, using the given SerializableSupplier to provide
an ExtensionRegistry to use in reading the given protobuf. |
|
static
|
PTypes.thrifts(Class<T> clazz,
PTypeFamily typeFamily)
Constructs a PType for a Thrift record. |
|
static PType<UUID> |
PTypes.uuid(PTypeFamily ptf)
A PType for Java's UUID type. |
Uses of PTypeFamily in org.apache.crunch.types.avro |
---|
Classes in org.apache.crunch.types.avro that implement PTypeFamily | |
---|---|
class |
AvroTypeFamily
|
Methods in org.apache.crunch.types.avro that return PTypeFamily | |
---|---|
PTypeFamily |
AvroType.getFamily()
|
Uses of PTypeFamily in org.apache.crunch.types.writable |
---|
Classes in org.apache.crunch.types.writable that implement PTypeFamily | |
---|---|
class |
WritableTypeFamily
The Writable -based implementation of the
PTypeFamily interface. |
Methods in org.apache.crunch.types.writable that return PTypeFamily | |
---|---|
PTypeFamily |
WritableType.getFamily()
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |